ストリームへのクエリ実行

Harbr のパイプラインでは、1 日を通して新しい出荷レコードが logistics.staging_shipments に取り込まれています。このテーブルには staging_shipments_stream というストリームがすでに設定されており、すべての挿入を追跡する準備ができています。今回の課題は、まずストリームが空であることを確認し、その後 2 件の新しいステージング出荷データを挿入して、ストリームがどのように変更を捉えたかをクエリで確認することです。

⚠️ データベースを選択できない、または「table not found」エラーが出る場合

FROM 句にはテーブルのフルパスを使用してください。左側パネルの「データベース」タブから COURSE_… データベースを展開し、対象のテーブルを選択して「Copy name」をクリックすると取得できます。