org.apache.beam.runners.fnexecution.control

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

java.lang.Object

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

Enclosing class:

ProcessBundleDescriptors

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

A container type storing references to the key, value, and window Coder used when handling bag user state requests.

Constructor Summary

Constructors

Constructor and Description
BagUserStateSpec()

Method Summary

Modifier and Type	Method and Description
abstract Coder<K>	keyCoder()
abstract java.lang.String	transformId()
abstract java.lang.String	userStateId()
abstract Coder<V>	valueCoder()
abstract Coder<W>	windowCoder()

Methods inherited from class java.lang.Object

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

Constructor Detail

BagUserStateSpec

public BagUserStateSpec()

Method Detail

transformId

public abstract java.lang.String transformId()

userStateId

public abstract java.lang.String userStateId()

keyCoder

public abstract Coder<K> keyCoder()

valueCoder

public abstract Coder<V> valueCoder()

windowCoder

public abstract Coder<W> windowCoder()