Returns a PTransform grouping all elements of the input PCollection together.
This is generally used with one or more combining specifications, as one
loses parallelization benefits in bringing all elements of a distributed
PCollection together on a single machine.
Various fields may be further aggregated with CombineFns by invoking
groupGlobally(...).combining(...).
Returns a PTransform grouping all elements of the input PCollection together.
This is generally used with one or more combining specifications, as one loses parallelization benefits in bringing all elements of a distributed PCollection together on a single machine.
Various fields may be further aggregated with
CombineFnsby invokinggroupGlobally(...).combining(...).