public class DeduplicatedFlattenFactory<T> extends java.lang.Object implements PTransformOverrideFactory<PCollectionList<T>,PCollection<T>,Flatten.PCollections<T>>
PTransformOverrideFactory
that will apply a flatten where no element appears in the
input PCollectionList
more than once.PTransformOverrideFactory.PTransformReplacement<InputT extends PInput,OutputT extends POutput>, PTransformOverrideFactory.ReplacementOutput
Modifier and Type | Method and Description |
---|---|
static <T> DeduplicatedFlattenFactory<T> |
create() |
PTransformOverrideFactory.PTransformReplacement<PCollectionList<T>,PCollection<T>> |
getReplacementTransform(AppliedPTransform<PCollectionList<T>,PCollection<T>,Flatten.PCollections<T>> transform)
Returns a
PTransform that produces equivalent output to the provided transform . |
java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput> |
mapOutputs(java.util.Map<TupleTag<?>,PCollection<?>> outputs,
PCollection<T> newOutput)
Returns a
Map from the expanded values in newOutput to the values produced by
the original transform. |
public static <T> DeduplicatedFlattenFactory<T> create()
public PTransformOverrideFactory.PTransformReplacement<PCollectionList<T>,PCollection<T>> getReplacementTransform(AppliedPTransform<PCollectionList<T>,PCollection<T>,Flatten.PCollections<T>> transform)
PTransformOverrideFactory
PTransform
that produces equivalent output to the provided transform
.getReplacementTransform
in interface PTransformOverrideFactory<PCollectionList<T>,PCollection<T>,Flatten.PCollections<T>>
public java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput> mapOutputs(java.util.Map<TupleTag<?>,PCollection<?>> outputs, PCollection<T> newOutput)
PTransformOverrideFactory
Map
from the expanded values in newOutput
to the values produced by
the original transform.mapOutputs
in interface PTransformOverrideFactory<PCollectionList<T>,PCollection<T>,Flatten.PCollections<T>>