GroupIntoBatches

Javadoc

入力を目的のバッチサイズにバッチ処理します。

バッチには、単一のキーの要素のみが含まれます。要素は、バッファされた要素数が`batchSize`に達するまでバッファリングされます。その後、これらの要素が出力コレクションに出力されます。

バッチには同じウィンドウからの要素が含まれるため、ウィンドウは保持されます。バッチには、複数のバンドルからの要素が含まれる場合があります。

例

関連トランスフォーム

• GroupByKeyは1つの入力コレクションを受け取ります。