Class SideInputParam<PCollT, AccessorT, ValueT>

Used to access side inputs corresponding to a given element from within a process() method.

See also https://beam.apache.org/documentation/programming-guide/#side-inputs

Type Parameters

  • PCollT

  • AccessorT

  • ValueT

Hierarchy

Constructors

constructor

Properties

accessor parDoParamName pcoll sideInputId

Methods

lookup

Constructors

constructor

  • Type Parameters

    • PCollT

    • AccessorT

    • ValueT

    Parameters

    • pcoll: PCollection<PCollT>
    • accessor: SideInputAccessor<PCollT, AccessorT, ValueT>

    Returns SideInputParam<PCollT, AccessorT, ValueT>

Properties

accessor

accessor: SideInputAccessor<PCollT, AccessorT, ValueT>

Readonly parDoParamName

parDoParamName: string

pcoll

pcoll: PCollection<PCollT>

sideInputId

sideInputId: string

Methods

lookup

Settings

Member Visibility

Theme

Generated using TypeDoc