Class: Rubadoop::MapReduce::Identity::Mapper

Inherits:

Mapper

• Object
• Mapper
• Rubadoop::MapReduce::Identity::Mapper

Defined in:

lib/rubadoop/map_reduce/identity.rb

Instance Method Summary

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

  A new instance of Mapper.

Methods included from Mappable

#mapper, #mapper_batched

Constructor Details

#initialize(config = {}) ⇒ Mapper

Returns a new instance of Mapper.

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

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

  mapper do |line|
    MapReduce.out.entry(line)
  end
end