org.apache.beam.runners.direct

Class ParDoMultiOverrideFactory<InputT,OutputT>

java.lang.Object

org.apache.beam.runners.direct.ParDoMultiOverrideFactory<InputT,OutputT>

All Implemented Interfaces:

org.apache.beam.sdk.runners.PTransformOverrideFactory<PCollection<? extends InputT>,PCollectionTuple,PTransform<PCollection<? extends InputT>,PCollectionTuple>>

public class ParDoMultiOverrideFactory<InputT,OutputT>
extends java.lang.Object
implements org.apache.beam.sdk.runners.PTransformOverrideFactory<PCollection<? extends InputT>,PCollectionTuple,PTransform<PCollection<? extends InputT>,PCollectionTuple>>

A PTransformOverrideFactory that provides overrides for applications of a ParDo in the direct runner. Currently overrides applications of Splittable DoFn.

Nested Class Summary

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

org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<InputT extends PInput,OutputT extends POutput>, org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput

Constructor Summary

Constructors

Constructor and Description
ParDoMultiOverrideFactory()

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<PCollection<? extends InputT>,PCollectionTuple>	getReplacementTransform(org.apache.beam.sdk.runners.AppliedPTransform<PCollection<? extends InputT>,PCollectionTuple,PTransform<PCollection<? extends InputT>,PCollectionTuple>> application)
java.util.Map<PValue,org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput>	mapOutputs(java.util.Map<TupleTag<?>,PValue> outputs, PCollectionTuple newOutput)

Methods inherited from class java.lang.Object

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

Constructor Detail

ParDoMultiOverrideFactory

public ParDoMultiOverrideFactory()

Method Detail

getReplacementTransform

public org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<PCollection<? extends InputT>,PCollectionTuple> getReplacementTransform(org.apache.beam.sdk.runners.AppliedPTransform<PCollection<? extends InputT>,PCollectionTuple,PTransform<PCollection<? extends InputT>,PCollectionTuple>> application)

Specified by:

getReplacementTransform in interface org.apache.beam.sdk.runners.PTransformOverrideFactory<PCollection<? extends InputT>,PCollectionTuple,PTransform<PCollection<? extends InputT>,PCollectionTuple>>

mapOutputs

public java.util.Map<PValue,org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput> mapOutputs(java.util.Map<TupleTag<?>,PValue> outputs,
                                                                                                                PCollectionTuple newOutput)

Specified by:

mapOutputs in interface org.apache.beam.sdk.runners.PTransformOverrideFactory<PCollection<? extends InputT>,PCollectionTuple,PTransform<PCollection<? extends InputT>,PCollectionTuple>>