Method: MapRedus::Reducer.reduce_perform

Defined in:
lib/mapredus/reducer.rb

.reduce_perform(process, key) ⇒ Object

The overridable portion of a reducer perform. In some default classes like Identity and Counter we do not call self.reduce but provide optimization for the reduction by overriding this method.



30
31
32
33
34
 
# File 'lib/mapredus/reducer.rb', line 30

def self.reduce_perform(process, key)
  reduce(process.map_values(key)) do |reduce_val|
    process.emit( key, reduce_val )
  end
end