展平

Javadoc

將多個 PCollection 物件合併為單一邏輯 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