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 Coder<K>	coder()
abstract TimerSpec	getTimerSpec()
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()

getTimerSpec

public abstract TimerSpec getTimerSpec()

coder

public abstract Coder<K> coder()