Package org.apache.beam.sdk.runners

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

java.lang.Object

org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<InputT,OutputT>

Enclosing interface:

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

public abstract static class PTransformOverrideFactory.PTransformReplacement<InputT extends PInput,OutputT extends POutput>
extends java.lang.Object

A PTransform that replaces an AppliedPTransform, and the input required to do so. The input must be constructed from the expanded form, as the transform may not have originally been applied within this process or from within a Java SDK.

Constructor Summary

Constructors

Constructor	Description
PTransformReplacement()

Method Summary

Modifier and Type	Method	Description
abstract InputT	getInput()
abstract PTransform<InputT,OutputT>	getTransform()
static <InputT extends PInput,OutputT extends POutput> PTransformOverrideFactory.PTransformReplacement<InputT,OutputT>	of(InputT input, PTransform<InputT,OutputT> transform)

Methods inherited from class java.lang.Object

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

Constructor Detail

PTransformReplacement

public PTransformReplacement()

Method Detail

of

public static <InputT extends PInput,OutputT extends POutput> PTransformOverrideFactory.PTransformReplacement<InputT,OutputT> of(InputT input,
                                                                                                                                             PTransform<InputT,OutputT> transform)

getInput

public abstract InputT getInput()

getTransform

public abstract PTransform<InputT,OutputT> getTransform()