InputT
- transform input typeOutputT
- transform output typeTransformT
- transform type@Internal public abstract class AppliedPTransform<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<? super InputT,OutputT>> extends java.lang.Object
Inputs and outputs are stored in their expanded forms, as the condensed form of a composite
PInput
or POutput
is a language-specific concept, and AppliedPTransform
represents a possibly cross-language transform for which no appropriate composite type exists in
the Java SDK.
Modifier and Type | Method and Description |
---|---|
abstract java.lang.String |
getFullName() |
abstract java.util.Map<TupleTag<?>,PCollection<?>> |
getInputs() |
java.util.Map<TupleTag<?>,PCollection<?>> |
getMainInputs() |
abstract java.util.Map<TupleTag<?>,PCollection<?>> |
getOutputs() |
abstract Pipeline |
getPipeline() |
abstract ResourceHints |
getResourceHints() |
abstract TransformT |
getTransform() |
static <InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<? super InputT,OutputT>> |
of(java.lang.String fullName,
java.util.Map<TupleTag<?>,PCollection<?>> input,
java.util.Map<TupleTag<?>,PCollection<?>> output,
TransformT transform,
ResourceHints resourceHints,
Pipeline p) |
public static <InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<? super InputT,OutputT>> AppliedPTransform<InputT,OutputT,TransformT> of(java.lang.String fullName, java.util.Map<TupleTag<?>,PCollection<?>> input, java.util.Map<TupleTag<?>,PCollection<?>> output, TransformT transform, ResourceHints resourceHints, Pipeline p)
public abstract java.lang.String getFullName()
public abstract java.util.Map<TupleTag<?>,PCollection<?>> getInputs()
public abstract java.util.Map<TupleTag<?>,PCollection<?>> getOutputs()
public abstract TransformT getTransform()
public abstract ResourceHints getResourceHints()
public abstract Pipeline getPipeline()
public java.util.Map<TupleTag<?>,PCollection<?>> getMainInputs()
TupleTags
which are not side inputs.