Method: Fairy::PGroupBy::DirectKBMergeSortBuffer::CachedBuffer#each_by_same_key
- Defined in:
- lib/fairy/node/p-group-by.rb
#each_by_same_key(&block) ⇒ Object
1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 |
# File 'lib/fairy/node/p-group-by.rb', line 1407 def each_by_same_key(&block) loop do @cache.each &block read_buffer return if @cache.empty? unless @njob.hash_key(@cache.first) == @key @key = @njob.hash_key(@cache.first) return end end end |