org.apache.beam.sdk.util.construction.graph

Class TimerReference

java.lang.Object

org.apache.beam.sdk.util.construction.graph.TimerReference

public abstract class TimerReference
extends java.lang.Object

Contains references to components relevant for runners during execution for timers. The referenced PTransform specifies the timer specification while the PCollection specifies the encoding representation.

Constructor Summary

Constructors

Constructor and Description
TimerReference()

Method Summary

Modifier and Type	Method and Description
static TimerReference	fromTimerId(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload.TimerId timerId, org.apache.beam.model.pipeline.v1.RunnerApi.Components components) Create a timer reference from a TimerId proto and components.
abstract java.lang.String	localName() The local name the referencing PTransform uses to refer to this timer.
static TimerReference	of(PipelineNode.PTransformNode transform, java.lang.String localName) Create a timer reference.
abstract PipelineNode.PTransformNode	transform() The PTransform that uses this timer.

Methods inherited from class java.lang.Object

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

Constructor Detail

TimerReference

public TimerReference()

Method Detail

of

public static TimerReference of(PipelineNode.PTransformNode transform,
                                java.lang.String localName)

Create a timer reference.

fromTimerId

public static TimerReference fromTimerId(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload.TimerId timerId,
                                         org.apache.beam.model.pipeline.v1.RunnerApi.Components components)

Create a timer reference from a TimerId proto and components.

transform

public abstract PipelineNode.PTransformNode transform()

The PTransform that uses this timer.

localName

public abstract java.lang.String localName()

The local name the referencing PTransform uses to refer to this timer.