Class: Rubadoop::MapReduce::Identity::Reducer

Inherits:

Reducer

• Object
• Reducer
• Rubadoop::MapReduce::Identity::Reducer

Defined in:

lib/rubadoop/map_reduce/identity.rb

Instance Method Summary

• #initialize(config = {}) ⇒ Reducer constructor

  A new instance of Reducer.

Methods included from Reducable

#reducer

Constructor Details

#initialize(config = {}) ⇒ Reducer

Returns a new instance of Reducer.

# File 'lib/rubadoop/map_reduce/identity.rb', line 16

def initialize(config = {})
  super(config)

  reducer do |key, values|
    values.each { |value|
      MapReduce.out.entry "#{key}\t#{value}" unless value.nil?
      MapReduce.out.entry key if value.nil?
    }
  end
end