Function pythonTransform

pythonTransform<InputT, OutputT>(constructor: string, args_or_kwargs?: undefined | any[] | {
[key: string]: any;
}, kwargs?: undefined | {
[key: string]: any;
}, options?: RawExternalTransformOptions): AsyncPTransform<InputT, OutputT>
Returns a PTransform applying a Python transform (typically identified by fully qualified name) to a PCollection, e.g.
```
const input_pcoll = ...
const output_pcoll = input_pcoll.apply(
    pythonTransform("beam.Map", [pythonCallable("str.upper")]));
```
See also https://beam.apache.org/documentation/programming-guide/#1324-using-cross-language-transforms-in-a-typescript-pipeline
Type Parameters
- InputT extends PValue<any>
- OutputT extends PValue<any>
Parameters
- constructor: string
- args_or_kwargs: undefined | any[] | {
  [key: string]: any;
  } = undefined
- kwargs: undefined | {
  [key: string]: any;
  } = undefined
- options: RawExternalTransformOptions = {}
Returns AsyncPTransform<InputT, OutputT>
- Defined in src/apache_beam/transforms/python.ts:44

Generated using TypeDoc