| CARVIEW |
Select Language
HTTP/2 200
server: Apache
last-modified: Sat, 19 Jul 2025 17:42:10 GMT
etag: "a174-63a4bc3199ef9-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: Sat, 19 Jul 2025 18:56:10 GMT
x-served-by: cache-hel1410025-HEL, cache-bom4739-BOM
x-cache: MISS, MISS
x-cache-hits: 0, 0
x-timer: S1752951370.481896,VS0,VE476
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/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!