@ThreadSafe public static interface StateRequestHandlers.SideInputHandlerFactory
StateRequestHandlers.MultimapSideInputHandler
s.
Note that this factory should be thread safe because it will be invoked concurrently.
Modifier and Type | Method and Description |
---|---|
<V,W extends BoundedWindow> |
forIterableSideInput(java.lang.String pTransformId,
java.lang.String sideInputId,
Coder<V> elementCoder,
Coder<W> windowCoder)
|
<K,V,W extends BoundedWindow> |
forMultimapSideInput(java.lang.String pTransformId,
java.lang.String sideInputId,
KvCoder<K,V> elementCoder,
Coder<W> windowCoder)
|
static StateRequestHandlers.SideInputHandlerFactory |
unsupported()
Throws a
UnsupportedOperationException on the first access. |
<V,W extends BoundedWindow> StateRequestHandlers.IterableSideInputHandler<V,W> forIterableSideInput(java.lang.String pTransformId, java.lang.String sideInputId, Coder<V> elementCoder, Coder<W> windowCoder)
StateRequestHandlers.IterableSideInputHandler
for the given pTransformId
, sideInputId
. The supplied elementCoder
and windowCoder
should be used to
encode/decode their respective values.<K,V,W extends BoundedWindow> StateRequestHandlers.MultimapSideInputHandler<K,V,W> forMultimapSideInput(java.lang.String pTransformId, java.lang.String sideInputId, KvCoder<K,V> elementCoder, Coder<W> windowCoder)
StateRequestHandlers.MultimapSideInputHandler
for the given pTransformId
, sideInputId
. The supplied elementCoder
and windowCoder
should be used to
encode/decode their respective values.static StateRequestHandlers.SideInputHandlerFactory unsupported()
UnsupportedOperationException
on the first access.