Package org.apache.beam.sdk.runners

Interface PTransformOverrideFactory<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<? super InputT,OutputT>>

@Internal
@Experimental(CORE_RUNNERS_ONLY)
public interface PTransformOverrideFactory<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<? super InputT,OutputT>>

For internal use only; no backwards-compatibility guarantees.

Produces PipelineRunner-specific overrides of PTransforms, and provides mappings between original and replacement outputs.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	PTransformOverrideFactory.PTransformReplacement<InputT extends PInput,OutputT extends POutput>	A PTransform that replaces an AppliedPTransform, and the input required to do so.
static class	PTransformOverrideFactory.ReplacementOutput	A mapping between original TaggedPValue outputs and their replacements.

Method Summary

Modifier and Type	Method	Description
PTransformOverrideFactory.PTransformReplacement<InputT,OutputT>	getReplacementTransform(AppliedPTransform<InputT,OutputT,TransformT> 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, OutputT newOutput)	Returns a Map from the expanded values in newOutput to the values produced by the original transform.

Method Detail

getReplacementTransform

PTransformOverrideFactory.PTransformReplacement<InputT,OutputT> getReplacementTransform(AppliedPTransform<InputT,OutputT,TransformT> transform)

Returns a PTransform that produces equivalent output to the provided transform.

mapOutputs

java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput> mapOutputs(java.util.Map<TupleTag<?>,PCollection<?>> outputs,
                                                                                           OutputT newOutput)

Returns a Map from the expanded values in newOutput to the values produced by the original transform.