org.apache.beam.sdk.util.construction

Class SplittableParDoNaiveBounded.OverrideFactory<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>

java.lang.Object

org.apache.beam.sdk.util.construction.SplittableParDoNaiveBounded.OverrideFactory<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>

All Implemented Interfaces:

PTransformOverrideFactory<PCollection<KV<byte[],KV<InputT,RestrictionT>>>,PCollectionTuple,SplittableParDo.ProcessKeyedElements<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>>

Enclosing class:

SplittableParDoNaiveBounded

public static class SplittableParDoNaiveBounded.OverrideFactory<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>
extends java.lang.Object
implements PTransformOverrideFactory<PCollection<KV<byte[],KV<InputT,RestrictionT>>>,PCollectionTuple,SplittableParDo.ProcessKeyedElements<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>>

Overrides a SplittableParDo.ProcessKeyedElements into SplittableProcessNaive.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.runners.PTransformOverrideFactory

PTransformOverrideFactory.PTransformReplacement<InputT extends PInput,OutputT extends POutput>, PTransformOverrideFactory.ReplacementOutput

Constructor Summary

Constructors

Constructor and Description
OverrideFactory()

Method Summary

Modifier and Type	Method and Description
PTransformOverrideFactory.PTransformReplacement<PCollection<KV<byte[],KV<InputT,RestrictionT>>>,PCollectionTuple>	getReplacementTransform(AppliedPTransform<PCollection<KV<byte[],KV<InputT,RestrictionT>>>,PCollectionTuple,SplittableParDo.ProcessKeyedElements<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>> 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, PCollectionTuple newOutput) Returns a Map from the expanded values in newOutput to the values produced by the original transform.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OverrideFactory

public OverrideFactory()

Method Detail

getReplacementTransform

public PTransformOverrideFactory.PTransformReplacement<PCollection<KV<byte[],KV<InputT,RestrictionT>>>,PCollectionTuple> getReplacementTransform(AppliedPTransform<PCollection<KV<byte[],KV<InputT,RestrictionT>>>,PCollectionTuple,SplittableParDo.ProcessKeyedElements<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>> transform)

Description copied from interface: PTransformOverrideFactory

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

Specified by:

getReplacementTransform in interface PTransformOverrideFactory<PCollection<KV<byte[],KV<InputT,RestrictionT>>>,PCollectionTuple,SplittableParDo.ProcessKeyedElements<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>>

mapOutputs

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

Description copied from interface: PTransformOverrideFactory

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

Specified by:

mapOutputs in interface PTransformOverrideFactory<PCollection<KV<byte[],KV<InputT,RestrictionT>>>,PCollectionTuple,SplittableParDo.ProcessKeyedElements<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>>