Querying a Stream

Harbr's pipeline ingests new shipment records into logistics.staging_shipments throughout the day. A stream called staging_shipments_stream already sits on that table and is ready to track every insert. Your task is to confirm the stream starts empty, then insert two new staging shipments and query the stream to see what it captured.