Method: Fairy::PGroupBy::SimpleFileByKeyBuffer#initialize

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

#initialize(njob, policy) ⇒ SimpleFileByKeyBuffer

Returns a new instance of SimpleFileByKeyBuffer.



216
217
218
219
220
221
222
223
224
225
226
 
# File 'lib/fairy/node/p-group-by.rb', line 216

def initialize(njob, policy)
  require "tempfile"

  @njob = njob
  @policy = policy

  @key_file = {}
  @key_file_mutex = Mutex.new
  @buffer_dir = policy[:buffer_dir]
  @buffer_dir ||= CONF.TMP_DIR
end