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 TimerSpec	getTimerSpec()
abstract java.lang.String	inputCollectionId()
abstract java.lang.String	outputCollectionId()
abstract java.lang.String	outputTransformId()
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()

inputCollectionId

public abstract java.lang.String inputCollectionId()

outputCollectionId

public abstract java.lang.String outputCollectionId()

outputTransformId

public abstract java.lang.String outputTransformId()

getTimerSpec

public abstract TimerSpec getTimerSpec()