org.apache.beam.runners.core.construction

Class SingleInputOutputOverrideFactory<InputT extends PValue,OutputT extends PValue,TransformT extends PTransform<InputT,OutputT>>

java.lang.Object

org.apache.beam.runners.core.construction.SingleInputOutputOverrideFactory<InputT,OutputT,TransformT>

All Implemented Interfaces:

PTransformOverrideFactory<InputT,OutputT,TransformT>

public abstract class SingleInputOutputOverrideFactory<InputT extends PValue,OutputT extends PValue,TransformT extends PTransform<InputT,OutputT>>
extends Object
implements PTransformOverrideFactory<InputT,OutputT,TransformT>

A PTransformOverrideFactory which consumes from a PValue and produces a PValue. mapOutputs(Map, PValue) is implemented.

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
SingleInputOutputOverrideFactory()

Method Summary

Modifier and Type	Method and Description
Map<PValue,PTransformOverrideFactory.ReplacementOutput>	mapOutputs(Map<TupleTag<?>,PValue> outputs, OutputT newOutput)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.runners.PTransformOverrideFactory

getReplacementTransform

Constructor Detail

SingleInputOutputOverrideFactory

public SingleInputOutputOverrideFactory()

Method Detail

mapOutputs

public final Map<PValue,PTransformOverrideFactory.ReplacementOutput> mapOutputs(Map<TupleTag<?>,PValue> outputs,
                                                                                OutputT newOutput)

Specified by:

mapOutputs in interface PTransformOverrideFactory<InputT extends PValue,OutputT extends PValue,TransformT extends PTransform<InputT,OutputT>>