Class: Fairy::PMergeGroupBy

Inherits:

PBasicGroupBy

• Object
• PFilter
• PIOFilter
• PBasicGroupBy
• Fairy::PMergeGroupBy

Defined in:

lib/fairy/node/p-merger-group-by.rb

Constant Summary

Constants inherited from PBasicGroupBy

Fairy::PBasicGroupBy::ST_ALL_IMPORTED, Fairy::PBasicGroupBy::ST_EXPORT_FINISH, Fairy::PBasicGroupBy::ST_WAIT_EXPORT_FINISH

Constants inherited from PIOFilter

Fairy::PIOFilter::ST_WAIT_IMPORT

Constants inherited from PFilter

Fairy::PFilter::END_OF_STREAM, Fairy::PFilter::ST_ACTIVATE, Fairy::PFilter::ST_FINISH, Fairy::PFilter::ST_INIT

Instance Attribute Summary

Attributes inherited from PFilter

#IGNORE_EXCEPTION, #id, #log_id, #ntask

Instance Method Summary

• #initialize(id, ntask, bjob, opts, block_source) ⇒ PMergeGroupBy constructor

  A new instance of PMergeGroupBy.

Methods inherited from PBasicGroupBy

#add_export, #hash_key, #init_key_proc, #start_export, #terminate, #wait_export_finish

Methods inherited from PIOFilter

#input=

Methods inherited from PFilter

#abort_running, #basic_start, #break_running, #each, #global_break, #global_break_from_other, #handle_exception, #key, #key=, #next, #no, #no=, #notice_status, #processor, #start, #start_export, #start_watch_status, #status=, #terminate, #terminate_proc

Constructor Details

#initialize(id, ntask, bjob, opts, block_source) ⇒ PMergeGroupBy

Returns a new instance of PMergeGroupBy.

# File 'lib/fairy/node/p-merger-group-by.rb', line 13

def initialize(id, ntask, bjob, opts, block_source)
  super
end