フラット化

Javadoc

複数のPCollectionオブジェクトを1つの論理PCollectionにマージします。

デフォルトでは、出力PCollectionのコーダーは、入力PCollectionListの最初のPCollectionのコーダーと同じです。ただし、入力PCollectionオブジェクトは、選択した言語で同じデータ型を含んでいる限り、それぞれ異なるコーダーを使用できます。

Flattenを使用してウィンドウ処理戦略が適用されたPCollectionオブジェクトをマージする場合、マージするすべてのPCollectionオブジェクトは、互換性のあるウィンドウ処理戦略とウィンドウサイズを使用する必要があります。たとえば、マージするすべてのコレクションは、（仮説的に）同一の5分間の固定ウィンドウまたは30秒ごとに開始する4分間のスライディングウィンドウをすべて使用する必要があります。

パイプラインがFlattenを使用して互換性のないウィンドウを持つPCollectionオブジェクトをマージしようとすると、パイプラインが構築されるときにBeamはIllegalStateExceptionエラーを生成します。

Beamプログラミングガイドで詳細を参照してください。

例

例：Flatten変換を適用して複数のPCollectionオブジェクトをマージする

結果のコレクションには、すべての要素「Hello」、「World」、「Beam」、「Is」、および「Fun」が含まれるようになりました。

関連する変換

• ParDo
• Partition