Class: MapRedus::RedisHasher

Inherits:
Outputter show all
Defined in:
lib/mapredus/default_classes.rb

Class Method Summary collapse

Methods inherited from Outputter

perform

Methods inherited from QueueProcess

perform, queue

Class Method Details

.decode(result_key, k) ⇒ Object



61
62
63
# File 'lib/mapredus/default_classes.rb', line 61

def self.decode(result_key, k)
  FileSystem.hget(result_key, k)
end

.encode(result_key, k, v) ⇒ Object



57
58
59
# File 'lib/mapredus/default_classes.rb', line 57

def self.encode(result_key, k, v)
  FileSystem.hset(result_key, k, v)
end

.keys(result_key) ⇒ Object



53
54
55
# File 'lib/mapredus/default_classes.rb', line 53

def self.keys(result_key)
  FileSystem.hkeys(result_key)
end

.to_hash(result_key) ⇒ Object



42
43
44
45
46
47
# File 'lib/mapredus/default_classes.rb', line 42

def self.to_hash(result_key)
  keys(result_key).inject({}) do |hash, key|
    hash[key] = decode(result_key, key)
    hash
  end
end

.values(result_key) ⇒ Object



49
50
51
# File 'lib/mapredus/default_classes.rb', line 49

def self.values(result_key)
  FileSystem.hvals(result_key)
end