# 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