@ThreadSafe public static interface StateRequestHandlers.BagUserStateHandlerFactory<K,V,W extends BoundedWindow>
StateRequestHandlers.BagUserStateHandler
s.
Note that this factory should be thread safe.
Modifier and Type | Method and Description |
---|---|
StateRequestHandlers.BagUserStateHandler<K,V,W> |
forUserState(java.lang.String pTransformId,
java.lang.String userStateId,
Coder<K> keyCoder,
Coder<V> valueCoder,
Coder<W> windowCoder) |
static <K,V,W extends BoundedWindow> |
unsupported()
Throws a
UnsupportedOperationException on the first access. |
StateRequestHandlers.BagUserStateHandler<K,V,W> forUserState(java.lang.String pTransformId, java.lang.String userStateId, Coder<K> keyCoder, Coder<V> valueCoder, Coder<W> windowCoder)
static <K,V,W extends BoundedWindow> StateRequestHandlers.BagUserStateHandlerFactory<K,V,W> unsupported()
UnsupportedOperationException
on the first access.