Method: Taps::DataStreamKeyed#initialize

Defined in:
lib/taps/data_stream.rb

#initialize(db, state) ⇒ DataStreamKeyed

Returns a new instance of DataStreamKeyed.



249
250
251
252
253
254
 
# File 'lib/taps/data_stream.rb', line 249

def initialize(db, state)
  super(db, state)
  @state = { :primary_key => order_by(state[:table_name]).first, :filter => 0 }.merge(state)
  @state[:chunksize] ||= DEFAULT_CHUNKSIZE
  @buffer = []
end