Wraps a PValue in a single object such that a transform can be applied to it.
For example, Flatten takes a PCollection[] as input, but Array has no apply(PTransformClass) method, so one writes
P([pcA, pcB, pcC]).apply(new Flatten())
Generated using TypeDoc
Wraps a PValue in a single object such that a transform can be applied to it.
For example, Flatten takes a PCollection[] as input, but Array has no apply(PTransformClass) method, so one writes
P([pcA, pcB, pcC]).apply(new Flatten())