GroupIntoBatches
JavadocBatches inputs to a desired batch size.
Batches contain only elements of a single key. Elements are buffered until
batchSize number of elements buffered. Then, these elements are output
to the output collection.
Batches contain elements from the same window, so windows are preserved. Batches might contain elements from more than one bundle.
Examples
Related transforms
- GroupByKey takes one input collection.
Last updated on 2024/11/19
Have you found everything you were looking for?
Was it all useful and clear? Is there anything that you would like to change? Let us know!