Package 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 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	Description
ParDoMultiOverrideFactory()

Method Summary

Modifier and Type	Method	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)
Map<PCollection<?>,org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput>	mapOutputs(Map<TupleTag<?>,PCollection<?>> outputs, PCollectionTuple newOutput)

Methods inherited from class java.lang.Object

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

Constructor Details

ParDoMultiOverrideFactory

public ParDoMultiOverrideFactory()

Method Details

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 Map<PCollection<?>,org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput> mapOutputs(Map<TupleTag<?>,PCollection<?>> outputs,
 PCollectionTuple newOutput)

Specified by:

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