分组到批次

Javadoc

将输入批处理到所需的批处理大小。

批次仅包含单个键的元素。元素被缓冲，直到缓冲 batchSize 个元素。然后，这些元素被输出到输出集合。

批次包含来自同一窗口的元素，因此窗口被保留。批次可能包含来自多个捆绑的元素。

示例

相关转换

• GroupByKey 接受一个输入集合。