Package org.apache.beam.runners.fnexecution.state

Interface StateRequestHandlers.BagUserStateHandlerFactory<K,V,W extends BoundedWindow>

All Known Implementing Classes:

InMemoryBagUserStateFactory

Enclosing class:

StateRequestHandlers

@ThreadSafe
public static interface StateRequestHandlers.BagUserStateHandlerFactory<K,V,W extends BoundedWindow>

A factory which constructs StateRequestHandlers.BagUserStateHandlers.

Note that this factory should be thread safe.

Method Summary

Modifier and Type	Method	Description
StateRequestHandlers.BagUserStateHandler<K,V,W>	forUserState(String pTransformId, String userStateId, Coder<K> keyCoder, Coder<V> valueCoder, Coder<W> windowCoder)
static <K, V, W extends BoundedWindow> StateRequestHandlers.BagUserStateHandlerFactory<K,V,W>	unsupported()	Throws a UnsupportedOperationException on the first access.

Method Details

forUserState

StateRequestHandlers.BagUserStateHandler<K,V,W> forUserState(String pTransformId,
 String userStateId,
 Coder<K> keyCoder,
 Coder<V> valueCoder,
 Coder<W> windowCoder)

unsupported

static <K,
V,
W extends BoundedWindow>
StateRequestHandlers.BagUserStateHandlerFactory<K,V,W> unsupported()

Throws a UnsupportedOperationException on the first access.