org.apache.beam.runners.fnexecution.control

Class ProcessBundleDescriptors.TimerSpec<K,V,W extends BoundedWindow>

java.lang.Object

org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.TimerSpec<K,V,W>

Enclosing class:

ProcessBundleDescriptors

public abstract static class ProcessBundleDescriptors.TimerSpec<K,V,W extends BoundedWindow>
extends java.lang.Object

A container type storing references to the key, timer and payload coders and the remote input destination used when handling timer requests.

Constructor Summary

Constructors

Constructor and Description
TimerSpec()

Method Summary

Modifier and Type	Method and Description
abstract java.lang.String	collectionId()
abstract TimerSpec	getTimerSpec()
abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.Target	outputTarget()
abstract java.lang.String	timerId()
abstract java.lang.String	transformId()

Methods inherited from class java.lang.Object

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

Constructor Detail

TimerSpec

public TimerSpec()

Method Detail

transformId

public abstract java.lang.String transformId()

timerId

public abstract java.lang.String timerId()

collectionId

public abstract java.lang.String collectionId()

outputTarget

public abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.Target outputTarget()

getTimerSpec

public abstract TimerSpec getTimerSpec()