public abstract class SideInputReference
extends java.lang.Object
Constructor and Description |
---|
SideInputReference() |
Modifier and Type | Method and Description |
---|---|
abstract PipelineNode.PCollectionNode |
collection()
The PCollection that backs this side input.
|
static SideInputReference |
fromSideInputId(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload.SideInputId sideInputId,
org.apache.beam.model.pipeline.v1.RunnerApi.Components components)
Create a side input reference from a SideInputId proto and components.
|
abstract java.lang.String |
localName()
The local name the referencing PTransform uses to refer to this side input.
|
static SideInputReference |
of(PipelineNode.PTransformNode transform,
java.lang.String localName,
PipelineNode.PCollectionNode collection)
Create a side input reference.
|
java.lang.String |
toString() |
abstract PipelineNode.PTransformNode |
transform()
The PTransform that uses this side input.
|
public static SideInputReference of(PipelineNode.PTransformNode transform, java.lang.String localName, PipelineNode.PCollectionNode collection)
public static SideInputReference fromSideInputId(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload.SideInputId sideInputId, org.apache.beam.model.pipeline.v1.RunnerApi.Components components)
public abstract PipelineNode.PTransformNode transform()
public abstract java.lang.String localName()
public abstract PipelineNode.PCollectionNode collection()
public final java.lang.String toString()
toString
in class java.lang.Object