| CARVIEW |
Select Language
HTTP/2 200
server: Apache
last-modified: Mon, 21 Jul 2025 11:40:41 GMT
etag: "a174-63a6ef2058944-gzip"
content-encoding: gzip
access-control-allow-origin: *
content-security-policy: frame-src 'self' https://play.beam.apache.org/ https://www.youtube.com/ https://drive.google.com/ ;
content-type: text/html
via: 1.1 varnish, 1.1 varnish
accept-ranges: bytes
age: 0
date: Mon, 21 Jul 2025 16:13:47 GMT
x-served-by: cache-hel1410025-HEL, cache-bom4735-BOM
x-cache: HIT, MISS
x-cache-hits: 2, 0
x-timer: S1753114427.079745,VS0,VE159
vary: Accept-Encoding
strict-transport-security: max-age=31536000; includeSubDomains; preload
content-length: 8821
GroupIntoBatches
GroupIntoBatches
Pydoc |
Batches the input into desired batch size.
Examples
In the following example, we create a pipeline with a PCollection of produce by season.
We use GroupIntoBatches to get fixed-sized batches for every key, which outputs a list of elements for every key.
Related transforms
For unkeyed data and dynamic batch sizes, one may want to use BatchElements.
|
Pydoc |
Last updated on 2025/07/21
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!