GroupIntoBatches

Javadoc

將輸入批次處理為所需的批次大小。

批次僅包含單一鍵的元素。 元素會被緩衝，直到緩衝了 batchSize 個元素。然後，這些元素會輸出到輸出集合。

批次包含來自同一個視窗的元素，因此視窗會被保留。 批次可能包含來自多個 bundle 的元素。

範例

相關 Transforms

• GroupByKey 接受一個輸入集合。