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.
PCollection
PCollections
apply
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
Generated using TypeDoc
A PTransform transforms an input PValue (such as a
PCollection
or set thereof) into an output PValue (which may consist of zero or morePCollections
). It is generally invoked by calling theapply
method on the input PValue, e.g.Any function from the input PValue type to the output PValueType is considered a valid PTransform, e.g.
See also the documentation on PTransforms at https://beam.apache.org/documentation/programming-guide/#transforms