Class: Wukong::Streamer::Reducer

Inherits:

ListReducer

• Object
• Base
• AccumulatingReducer
• ListReducer
• Wukong::Streamer::Reducer

Defined in:

lib/wukong/streamer/reducer.rb

Instance Attribute Summary

Attributes inherited from ListReducer

#values

Attributes inherited from AccumulatingReducer

#key

Attributes inherited from Base

#own_options

Instance Method Summary

• #finalize(&block) ⇒ Object

Methods inherited from ListReducer

#accumulate, #start!

Methods inherited from AccumulatingReducer

#accumulate, #after_stream, #before_stream, #get_key, #process, #start!

Methods inherited from Base

#after_stream, #bad_record!, #before_stream, #each_record, #emit, #initialize, #mapper, mapper, #monitor, #options, #process, #recordize, #run, run, #stream, #track

Constructor Details

This class inherits a constructor from Wukong::Streamer::Base

Instance Method Details

#finalize(&block) ⇒ Object

# File 'lib/wukong/streamer/reducer.rb', line 5

def finalize &block
  reduce @values, &block
end