Package 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 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	Description
TimerSpec()

Method Summary

Modifier and Type	Method	Description
abstract Coder<K>	coder()
abstract TimerSpec	getTimerSpec()
abstract String	timerId()
abstract String	transformId()

Methods inherited from class java.lang.Object

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

Constructor Details

TimerSpec

public TimerSpec()

Method Details

transformId

public abstract String transformId()

timerId

public abstract String timerId()

getTimerSpec

public abstract TimerSpec getTimerSpec()

coder

public abstract Coder<K> coder()