Class GroupBy<T, K>

A PTransformClass that takes a PCollection of elements, and returns a PCollection of elements grouped by a field, multiple fields, an expression that is used as the grouping key.

Type Parameters

  • T

  • K

Hierarchy

Constructors

constructor

Properties

beamName keyFn keyName keyNames

Methods

combining expandAsync expandInternal expandInternalAsync

Constructors

constructor

  • Create a GroupBy transform.

    Type Parameters

    • T

    • K

    Parameters

    • key: string | string[] | ((element: T) => K)
    • keyName: undefined | string = undefined

    Returns GroupBy<T, K>

Properties

beamName

beamName: string | (() => string)

keyFn

keyFn: ((element: T) => K)

Type declaration

    • (element: T): K

    • Parameters

      • element: T

      Returns K

keyName

keyName: string

keyNames

keyNames: string | string[]

Methods

combining

  • Type Parameters

    • I

    Parameters

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

    Returns GroupByAndCombine<T, unknown>

expandAsync

expandInternal

expandInternalAsync

Settings

Member Visibility

Theme

Generated using TypeDoc