Class: Fairy::PGroupBy::DirectFBMergeSortBuffer
- Inherits:
-
DirectMergeSortBuffer
- Object
- DirectOnMemoryBuffer
- DirectMergeSortBuffer
- Fairy::PGroupBy::DirectFBMergeSortBuffer
- Defined in:
- lib/fairy/node/p-group-by.rb
Defined Under Namespace
Classes: CachedBuffer, Merger
Instance Attribute Summary
Attributes inherited from DirectOnMemoryBuffer
Instance Method Summary collapse
Methods inherited from DirectMergeSortBuffer
#each, #init_2ndmemory, #initialize, #open_buffer, #push, #store_2ndmemory
Methods inherited from DirectOnMemoryBuffer
Constructor Details
This class inherits a constructor from Fairy::PGroupBy::DirectMergeSortBuffer
Instance Method Details
#each_2ndmemory(&block) ⇒ Object
1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 |
# File 'lib/fairy/node/p-group-by.rb', line 1173 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 = Merger.new(@njob, @buffers) m.each(&block) end |