Method: Fairy::PGroupBy#initialize

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

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

Returns a new instance of PGroupBy.



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/fairy/node/p-group-by.rb', line 15

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

  @exports = []
  def @exports.each_pair(&block)
  each_with_index do |item, idx| 
    block.call(idx, item) if item
    unless item
 Log::debug(self, "No assgined Export")
    end
  end
  end

  @mod = opts[:no_segment] 
  @mod ||= CONF.GROUP_BY_NO_SEGMENT
  Log::debug(self, "NO_SEGMENT: #{@mod}")

  mod = opts[:hash_module]
  mod ||= CONF.GROUP_BY_HASH_MODULE
  require mod
  @hash_generator = Fairy::HValueGenerator.new(bjob.hash_seed)

  @hash_optimize = CONF.GROUP_BY_GROUPING_OPTIMIZE
  @hash_optimize = opts[:grouping_optimize] if opts.key?(:grouping_optimize)
end