org.apache.beam.runners.fnexecution.state

Interface StateRequestHandlers.BagUserStateHandlerFactory

Enclosing class:

StateRequestHandlers

@ThreadSafe
public static interface StateRequestHandlers.BagUserStateHandlerFactory

A factory which constructs StateRequestHandlers.BagUserStateHandlers.

Note that this factory should be thread safe.

Method Summary

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

Method Detail

forUserState

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

unsupported

static StateRequestHandlers.BagUserStateHandlerFactory unsupported()

Throws a UnsupportedOperationException on the first access.