Package org.apache.beam.sdk.state
Interface StateBinder
-
@Internal public interface StateBinder
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <T> BagState<T>
bindBag(java.lang.String id, StateSpec<BagState<T>> spec, Coder<T> elemCoder)
<InputT,AccumT,OutputT>
CombiningState<InputT,AccumT,OutputT>bindCombining(java.lang.String id, StateSpec<CombiningState<InputT,AccumT,OutputT>> spec, Coder<AccumT> accumCoder, Combine.CombineFn<InputT,AccumT,OutputT> combineFn)
<InputT,AccumT,OutputT>
CombiningState<InputT,AccumT,OutputT>bindCombiningWithContext(java.lang.String id, StateSpec<CombiningState<InputT,AccumT,OutputT>> spec, Coder<AccumT> accumCoder, CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> combineFn)
<KeyT,ValueT>
MapState<KeyT,ValueT>bindMap(java.lang.String id, StateSpec<MapState<KeyT,ValueT>> spec, Coder<KeyT> mapKeyCoder, Coder<ValueT> mapValueCoder)
<T> OrderedListState<T>
bindOrderedList(java.lang.String id, StateSpec<OrderedListState<T>> spec, Coder<T> elemCoder)
<T> SetState<T>
bindSet(java.lang.String id, StateSpec<SetState<T>> spec, Coder<T> elemCoder)
<T> ValueState<T>
bindValue(java.lang.String id, StateSpec<ValueState<T>> spec, Coder<T> coder)
WatermarkHoldState
bindWatermark(java.lang.String id, StateSpec<WatermarkHoldState> spec, TimestampCombiner timestampCombiner)
Bind to a watermarkStateSpec
.
-
-
-
Method Detail
-
bindValue
<T> ValueState<T> bindValue(java.lang.String id, StateSpec<ValueState<T>> spec, Coder<T> coder)
-
bindBag
<T> BagState<T> bindBag(java.lang.String id, StateSpec<BagState<T>> spec, Coder<T> elemCoder)
-
bindSet
<T> SetState<T> bindSet(java.lang.String id, StateSpec<SetState<T>> spec, Coder<T> elemCoder)
-
bindMap
<KeyT,ValueT> MapState<KeyT,ValueT> bindMap(java.lang.String id, StateSpec<MapState<KeyT,ValueT>> spec, Coder<KeyT> mapKeyCoder, Coder<ValueT> mapValueCoder)
-
bindOrderedList
<T> OrderedListState<T> bindOrderedList(java.lang.String id, StateSpec<OrderedListState<T>> spec, Coder<T> elemCoder)
-
bindCombining
<InputT,AccumT,OutputT> CombiningState<InputT,AccumT,OutputT> bindCombining(java.lang.String id, StateSpec<CombiningState<InputT,AccumT,OutputT>> spec, Coder<AccumT> accumCoder, Combine.CombineFn<InputT,AccumT,OutputT> combineFn)
-
bindCombiningWithContext
<InputT,AccumT,OutputT> CombiningState<InputT,AccumT,OutputT> bindCombiningWithContext(java.lang.String id, StateSpec<CombiningState<InputT,AccumT,OutputT>> spec, Coder<AccumT> accumCoder, CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> combineFn)
-
bindWatermark
WatermarkHoldState bindWatermark(java.lang.String id, StateSpec<WatermarkHoldState> spec, TimestampCombiner timestampCombiner)
Bind to a watermarkStateSpec
.This accepts the
TimestampCombiner
that dictates how watermark hold timestamps added to the returnedWatermarkHoldState
are to be combined.
-
-