Javadoc Javadoc

Batches 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.