# File lib/taps/data_stream.rb, line 250 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