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 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()

inputCollectionId

public abstract java.lang.String inputCollectionId()

outputCollectionId

public abstract java.lang.String outputCollectionId()

outputTarget

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

getTimerSpec

public abstract TimerSpec getTimerSpec()