Package org.apache.beam.sdk.runners
Class AppliedPTransform<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<? super InputT,OutputT>>
- java.lang.Object
-
- org.apache.beam.sdk.runners.AppliedPTransform<InputT,OutputT,TransformT>
-
- Type Parameters:
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
For internal use only; no backwards-compatibility guarantees.Inputs and outputs are stored in their expanded forms, as the condensed form of a composite
PInput
orPOutput
is a language-specific concept, andAppliedPTransform
represents a possibly cross-language transform for which no appropriate composite type exists in the Java SDK.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method 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>>
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)
-
-
-
Method Detail
-
of
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)
-
getFullName
public abstract java.lang.String getFullName()
-
getInputs
public abstract java.util.Map<TupleTag<?>,PCollection<?>> getInputs()
-
getOutputs
public abstract java.util.Map<TupleTag<?>,PCollection<?>> getOutputs()
-
getTransform
public abstract TransformT getTransform()
-
getResourceHints
public abstract ResourceHints getResourceHints()
-
getPipeline
public abstract Pipeline getPipeline()
-
getMainInputs
public java.util.Map<TupleTag<?>,PCollection<?>> getMainInputs()
- Returns:
- map of
TupleTags
which are not side inputs.
-
-