GroupByKey

Javadoc

採用鍵值集合的元素，並產生一個集合，其中每個元素包含一個鍵和該鍵相關聯的所有值的 Iterable。

結果可以與視窗化結合使用，以根據時間或觸發器細分每個鍵，產生部分聚合。處理無邊界的集合時，視窗化或觸發是必要的。

請參閱 Beam 程式設計指南中的更多資訊。

範例

相關轉換

• CoGroupByKey 用於多個輸入集合
• Combine 用於將與鍵相關聯的所有值合併為單一結果