# File lib/taps/data_stream.rb, line 330
  def verify_stream
    key = primary_key
    ds = table.order(*order_by)
    current_filter = ds.max(key.sql_number)

    # set the current filter to the max of the primary key
    state[:filter] = current_filter
    # clear out the last_fetched value so it can restart from scratch
    state[:last_fetched] = nil

    log.debug "DataStreamKeyed#verify_stream -> state: #{state.inspect}"
  end