GroupByKey

Javadoc

キー付き要素のコレクションを受け取り、各要素がキーと、そのキーに関連付けられたすべての値のIterableで構成されるコレクションを生成します。

結果は、ウィンドウ処理で時間に基づいて各キーを細分化したり、トリガー処理で部分的な集計を生成するために組み合わせることができます。非有界コレクションを処理する場合は、ウィンドウ処理またはトリガー処理のいずれかが必要です。

Beam プログラミングガイドで詳細をご覧ください。

例

関連する変換

• 複数の入力コレクションに対するCoGroupByKey
• キーに関連付けられたすべての値を単一の結果に結合するためのCombine