Method: Fairy::PBasicMGroupBy#initialize

Defined in:
lib/fairy/node/p-basic-group-by.rb

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

Returns a new instance of PBasicMGroupBy.



124
125
126
127
128
129
130
131
132
133
134
135
 
# File 'lib/fairy/node/p-basic-group-by.rb', line 124

def initialize(id, ntask, bjob, opts, block_source)
  super
  @block_source = block_source
#      @key_proc = eval("proc{#{@block_source}}", TOPLEVEL_BINDING)
#      @key_proc = @context.create_proc(@block_source)
  @key_proc = BBlock.new(@block_source, @context, self)

  @exports = {}
  @exports_queue = XThread::Queue.new

#      start_watch_exports
end