T - the type of the elements in the input and output
PCollections.public static class Flatten.FlattenPCollectionList<T> extends PTransform<PCollectionList<T>,PCollection<T>>
PTransform that flattens a PCollectionList
into a PCollection containing all the elements of all
the PCollections in its input.name| Modifier and Type | Method and Description |
|---|---|
PCollection<T> |
apply(PCollectionList<T> inputs)
Applies this
PTransform on the given Input, and returns its
Output. |
protected Coder<?> |
getDefaultOutputCoder()
Returns the default
Coder to use for the output of this
single-output PTransform, or null if
none can be inferred. |
finishSpecifying, getCoderRegistry, getDefaultName, getDefaultOutputCoder, getInput, getKindString, getName, getOutput, getPipeline, setName, setPipeline, toString, withNamepublic PCollection<T> apply(PCollectionList<T> inputs)
PTransformPTransform on the given Input, and returns its
Output.
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).
The default implementation throws an exception. A derived class must
either implement apply, or else each runner must supply a custom
implementation via
PipelineRunner.apply(com.google.cloud.dataflow.sdk.transforms.PTransform<Input, Output>, Input).
apply in class PTransform<PCollectionList<T>,PCollection<T>>protected Coder<?> getDefaultOutputCoder()
PTransformCoder to use for the output of this
single-output PTransform, or null if
none can be inferred.
By default, returns null.
getDefaultOutputCoder in class PTransform<PCollectionList<T>,PCollection<T>>