Package 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 Object

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

Constructor Summary

Constructors

Constructor	Description
BagUserStateSpec()

Method Summary

Modifier and Type	Method	Description
abstract Coder<K>	keyCoder()
abstract String	transformId()
abstract 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 Details

BagUserStateSpec

public BagUserStateSpec()

Method Details

transformId

public abstract String transformId()

userStateId

public abstract String userStateId()

keyCoder

public abstract Coder<K> keyCoder()

valueCoder

public abstract Coder<V> valueCoder()

windowCoder

public abstract Coder<W> windowCoder()