org.apache.beam.runners.core.construction

Class PTransformReplacements

java.lang.Object

org.apache.beam.runners.core.construction.PTransformReplacements

public class PTransformReplacements
extends Object

Constructor Summary

Constructors

Constructor and Description
PTransformReplacements()

Method Summary

Modifier and Type	Method and Description
static <T> PCollection<T>	getSingletonMainInput(AppliedPTransform<? extends PCollection<? extends T>,?,?> application) Gets the singleton input of an AppliedPTransform, ignoring any additional inputs returned by PTransform.getAdditionalInputs().

Methods inherited from class java.lang.Object

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

Constructor Detail

PTransformReplacements

public PTransformReplacements()

Method Detail

getSingletonMainInput

public static <T> PCollection<T> getSingletonMainInput(AppliedPTransform<? extends PCollection<? extends T>,?,?> application)

Gets the singleton input of an AppliedPTransform, ignoring any additional inputs returned by PTransform.getAdditionalInputs().