Method: Fairy::PGroupBy::DirectKB2MergeSortBuffer#each_2ndmemory

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

#each_2ndmemory(&block) ⇒ Object 



1465
1466
1467
1468
1469
1470
1471
1472
1473
1474
1475
 
# File 'lib/fairy/node/p-group-by.rb', line 1465

def each_2ndmemory(&block)
  unless @key_values.empty?
    store_2ndmemory(@key_values)
    @key_values = nil
  end
  Log::info(self, "Merge Start: #{@buffers.size} files")
  Log::debug(self, @buffers.collect{|b| b.path}.join(" "))
  
  m = DirectMergeSortBuffer::Merger.new(@njob, @buffers, CachedBuffer)
  m.each(&block)
end