Method: Fairy::PGroupBy::DirectKBMergeSortBuffer#store_2ndmemory
- Defined in:
- lib/fairy/node/p-group-by.rb
#store_2ndmemory(key_values) ⇒ Object
1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 |
# File 'lib/fairy/node/p-group-by.rb', line 1352 def store_2ndmemory(key_values) Log::debug(self, "START STORE") sorted = key_values.sort_by{|e| e.first} open_buffer do |io| sorted.each do |key, vv| vv.each do |values| Marshal.dump(values, io) end end end sorted = nil Log::debug(self, "FINISH STORE") end |