Package org.apache.beam.sdk.runners

Class PTransformOverrideFactory.ReplacementOutput

java.lang.Object

org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput

Enclosing interface:

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

public abstract static class PTransformOverrideFactory.ReplacementOutput
extends java.lang.Object

A mapping between original TaggedPValue outputs and their replacements.

Constructor Summary

Constructors

Constructor	Description
ReplacementOutput()

Method Summary

Modifier and Type	Method	Description
abstract TaggedPValue	getOriginal()
abstract TaggedPValue	getReplacement()
static PTransformOverrideFactory.ReplacementOutput	of(TaggedPValue original, TaggedPValue replacement)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplacementOutput

public ReplacementOutput()

Method Detail

of

public static PTransformOverrideFactory.ReplacementOutput of(TaggedPValue original,
                                                             TaggedPValue replacement)

getOriginal

public abstract TaggedPValue getOriginal()

getReplacement

public abstract TaggedPValue getReplacement()