Class: Fairy::PGroupBy::DirectFBMergeSortBuffer::Merger

Inherits:
Fairy::PGroupBy::DirectMergeSortBuffer::Merger show all
Defined in:
lib/fairy/node/p-group-by.rb

Instance Method Summary collapse

Methods inherited from Fairy::PGroupBy::DirectMergeSortBuffer::Merger

#each, #each_by_key, #get_buf

Constructor Details

#initialize(njob, buffers) ⇒ Merger

Returns a new instance of Merger.



1186
1187
1188
1189
1190
1191
 
# File 'lib/fairy/node/p-group-by.rb', line 1186

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