Type alias PTransform<InputT, OutputT>

PTransform<InputT, OutputT>: PTransformClass<InputT, OutputT> | ((input: InputT) => OutputT) | ((input: InputT, pipeline: Pipeline, transformProto: runnerApi.PTransform) => OutputT)

A PTransform transforms an input PValue (such as a PCollection or set thereof) into an output PValue (which may consist of zero or more PCollections). It is generally invoked by calling the apply method on the input PValue, e.g.

const PCollection<T> input_pcoll = ...
const PCollection<O> output_pcoll = input_pcoll.apply(
MyPTransform<PCollection<T>>, PCollection<O>>);

Any function from the input PValue type to the output PValueType is considered a valid PTransform, e.g.

const PCollection<T> input_pcoll = ...
const PCollection<O> output_pcoll = input_pcoll.apply(
new function(input: PCollection<T>>): PCollection<O>> {...});

See also the documentation on PTransforms at https://beam.apache.org/documentation/programming-guide/#transforms

Type Parameters

Generated using TypeDoc