Class PCollection<T>

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

Type Parameters

T

Hierarchy

PCollection

Index

Properties

Methods

apply applyAsync flatMap map root

Properties

`Private` computeId

computeId: (() => string)

Type declaration

- (): string
- Returns string

`Private` id

id: string

Methods

apply

apply<OutputT>(transform: PTransform<PCollection<T>, OutputT>): any
Type Parameters
- OutputT extends PValue<any>
Parameters
- transform: PTransform<PCollection<T>, OutputT>
Returns any
- Defined in src/apache_beam/pvalue.ts:92

applyAsync

applyAsync<OutputT>(transform: AsyncPTransform<PCollection<T>, OutputT>): any
Type Parameters
- OutputT extends PValue<any>
Parameters
- transform: AsyncPTransform<PCollection<T>, OutputT>
Returns any
- Defined in src/apache_beam/pvalue.ts:101

flatMap

flatMap<OutputT, ContextT>(fn: (ContextT extends undefined ? ((element: T) => Iterable<OutputT>) : never) | ((element: T, context: ContextT) => Iterable<OutputT>), context?: ContextT): PCollection<OutputT>
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>
- Defined in src/apache_beam/pvalue.ts:138

map

map<OutputT, ContextT>(fn: (ContextT extends undefined ? ((element: T) => OutputT) : never) | ((element: T, context: ContextT) => OutputT), context?: ContextT): 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>
- Defined in src/apache_beam/pvalue.ts:110

root

root(): Root
Returns Root
- Defined in src/apache_beam/pvalue.ts:166

Generated using TypeDoc