Class GroupGlobally<T>

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

Type Parameters

  • T

Hierarchy

Constructors

constructor

Properties

beamName

Methods

combining expandAsync expandInternal expandInternalAsync

Constructors

constructor

Properties

beamName

beamName: string | (() => string)

Methods

combining

  • Type Parameters

    • I

    Parameters

    • expr: string | ((element: T) => I)
    • combiner: Combiner<I>
    • resultName: string

    Returns GroupByAndCombine<unknown, unknown>

expandAsync

expandInternal

expandInternalAsync

Settings

Member Visibility

Theme

Generated using TypeDoc