Method: Fairy::PGroupBy::DirectFBMergeSortBuffer::Merger#initialize

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

#initialize(njob, buffers) ⇒ Merger

Returns a new instance of Merger.



1197
1198
1199
1200
1201
1202
 
# File 'lib/fairy/node/p-group-by.rb', line 1197

def initialize(njob, buffers)
  @njob = njob
  @buffers = buffers.collect{|buf| CachedBuffer.new(@njob, buf)}.select{|buf| !buf.eof?}.sort_by{|buf| buf.key}

  @key = nil
end