Method: Fairy::PGroupBy::DirectKBMergeSortBuffer::CachedBuffer#initialize

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

#initialize(njob, io) ⇒ CachedBuffer

Returns a new instance of CachedBuffer.



1382
1383
1384
1385
1386
1387
1388
1389
1390
1391
1392
1393
 
# File 'lib/fairy/node/p-group-by.rb', line 1382

def initialize(njob, io)
  @njob = njob
  @io = io
  io.open

  @cache = []

  @eof = false

  read_buffer
  @key = @njob.hash_key(@cache.first)
end