Beam SQL拡張機能:結合

Beam SQLでサポートされている`JOIN`タイプ

Beam SQLでサポートされていない`JOIN`タイプ

結合のシナリオは3つのケースに分類できます。

  1. バウンド入力`JOIN`バウンド入力
  2. アンバウンド入力`JOIN`アンバウンド入力
  3. アンバウンド入力`JOIN`バウンド入力

バウンドJOINバウンド

標準的な結合実装が使用されます。一方の入力からのすべての要素が、もう一方の入力からのすべての要素と照合されます。両方の入力がバウンドされているため、ウィンドウ処理やトリガーは関与しません。

アンバウンドJOINアンバウンド

標準的な結合実装が使用されます。一方の入力からのすべての要素が、もう一方の入力からのすべての要素と照合されます。

ウィンドウ処理とトリガー

アンバウンド入力を結合する場合は、次のプロパティを満たす必要があります。

これは、入力がウィンドウごとに結合されることを意味します。つまり、トリガーが発火すると(1回のみ)、両方の入力の現在のウィンドウ内のすべての要素に対して結合が実行されます。これにより、どのような種類の出力が生成されるかを推論できます。

**注:** `GroupByKeys`と同様に、`JOIN`は`Trigger.continuationTrigger()`を使用してトリガーを更新します。入力のウィンドウ処理戦略の他の側面は変更されません。

アンバウンドJOINバウンド

このタイプの`JOIN`では、バウンド入力は実装によってサイド入力として扱われます。これは、ウィンドウ/トリガーがアップストリームから継承されることを意味します。