public abstract class UserStateReference
extends java.lang.Object
Constructor and Description |
---|
UserStateReference() |
Modifier and Type | Method and Description |
---|---|
abstract PipelineNode.PCollectionNode |
collection()
The PCollection that represents the input to the PTransform.
|
static UserStateReference |
fromUserStateId(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload.UserStateId userStateId,
org.apache.beam.model.pipeline.v1.RunnerApi.Components components)
Create a user state reference from a UserStateId proto and components.
|
abstract java.lang.String |
localName()
The local name the referencing PTransform uses to refer to this user state.
|
static UserStateReference |
of(PipelineNode.PTransformNode transform,
java.lang.String localName,
PipelineNode.PCollectionNode collection)
Create a user state reference.
|
abstract PipelineNode.PTransformNode |
transform()
The id of the PTransform that uses this user state.
|
public static UserStateReference of(PipelineNode.PTransformNode transform, java.lang.String localName, PipelineNode.PCollectionNode collection)
public static UserStateReference fromUserStateId(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload.UserStateId userStateId, 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()