Class PCollection<T>

A deferred, possibly distributed collection of elements. See https://beam.apache.org/documentation/programming-guide/#pcollections

Type Parameters

  • T

Hierarchy

  • PCollection

Properties

Methods

Properties

computeId: (() => string)

Type declaration

    • (): string
    • Returns string

id: string

Methods

  • Type Parameters

    • OutputT

    • ContextT

    Parameters

    • fn: (ContextT extends undefined ? ((element: T) => Iterable<OutputT>) : never) | ((element: T, context: ContextT) => Iterable<OutputT>)
    • context: ContextT = ...

    Returns PCollection<OutputT>

  • Type Parameters

    • OutputT

    • ContextT

    Parameters

    • fn: (ContextT extends undefined ? ((element: T) => OutputT) : never) | ((element: T, context: ContextT) => OutputT)
    • context: ContextT = ...

    Returns PCollection<OutputT>

Generated using TypeDoc