Class: MapRedus::Outputter

Inherits:

QueueProcess

• Object
• QueueProcess
• MapRedus::Outputter

Defined in:

lib/mapredus/outputter.rb

Overview

Standard readers for the input and output of Files coming out of the FileSystem.

Direct Known Subclasses

JsonOutputter, RedisHasher

Class Method Summary

• .decode(result_key) ⇒ Object
• .encode(result_key, o) ⇒ Object
• .perform(type, o) ⇒ Object

  type should either be “decode” or “encode”.

Methods inherited from QueueProcess

queue

Class Method Details

.decode(result_key) ⇒ Object

# File 'lib/mapredus/outputter.rb', line 7

def self.decode(result_key)
  FileSystem.get(result_key)
end

.encode(result_key, o) ⇒ Object

# File 'lib/mapredus/outputter.rb', line 11

def self.encode(result_key, o)
  FileSystem.set(result_key, o)
end

.perform(type, o) ⇒ Object

type should either be “decode” or “encode”

# File 'lib/mapredus/outputter.rb', line 18

def self.perform(type, o)
  send(type, o)
end