Function parDo

parDo<InputT, OutputT, ContextT>(doFn: DoFn<InputT, OutputT, ContextT>, context?: ContextT): PTransform<PCollection<InputT>, PCollection<OutputT>>
Creates a PTransform that applies a DoFn to a PCollection.
Type Parameters
- InputT
- OutputT
- ContextT extends undefined | Object = undefined
Parameters
- doFn: DoFn<InputT, OutputT, ContextT>
- context: ContextT = ...
Returns PTransform<PCollection<InputT>, PCollection<OutputT>>
- Defined in src/apache_beam/transforms/pardo.ts:85

Generated using TypeDoc