Package org.apache.beam.sdk.state

Interface StateBinder

All Known Implementing Classes:

FlinkStateInternals.EarlyBinder

@Internal
public interface StateBinder

For internal use only; no backwards-compatibility guarantees.

Visitor for binding a StateSpec and to the associated State.

Method Summary

Modifier and Type	Method	Description
<T> BagState<T>	bindBag(String id, StateSpec<BagState<T>> spec, Coder<T> elemCoder)
<InputT, AccumT, OutputT> CombiningState<InputT,AccumT,OutputT>	bindCombining(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(String id, StateSpec<CombiningState<InputT,AccumT,OutputT>> spec, Coder<AccumT> accumCoder, CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> combineFn)
<KeyT, ValueT> MapState<KeyT,ValueT>	bindMap(String id, StateSpec<MapState<KeyT,ValueT>> spec, Coder<KeyT> mapKeyCoder, Coder<ValueT> mapValueCoder)
<KeyT, ValueT> MultimapState<KeyT,ValueT>	bindMultimap(String id, StateSpec<MultimapState<KeyT,ValueT>> spec, Coder<KeyT> keyCoder, Coder<ValueT> valueCoder)
<T> OrderedListState<T>	bindOrderedList(String id, StateSpec<OrderedListState<T>> spec, Coder<T> elemCoder)
<T> SetState<T>	bindSet(String id, StateSpec<SetState<T>> spec, Coder<T> elemCoder)
<T> ValueState<T>	bindValue(String id, StateSpec<ValueState<T>> spec, Coder<T> coder)
WatermarkHoldState	bindWatermark(String id, StateSpec<WatermarkHoldState> spec, TimestampCombiner timestampCombiner)	Bind to a watermark StateSpec.

Method Details

bindValue

<T> ValueState<T> bindValue(String id,
 StateSpec<ValueState<T>> spec,
 Coder<T> coder)

bindBag

<T> BagState<T> bindBag(String id,
 StateSpec<BagState<T>> spec,
 Coder<T> elemCoder)

bindSet

<T> SetState<T> bindSet(String id,
 StateSpec<SetState<T>> spec,
 Coder<T> elemCoder)

bindMap

<KeyT,
ValueT> MapState<KeyT,ValueT> bindMap(String id,
 StateSpec<MapState<KeyT,ValueT>> spec,
 Coder<KeyT> mapKeyCoder,
 Coder<ValueT> mapValueCoder)

bindOrderedList

<T> OrderedListState<T> bindOrderedList(String id,
 StateSpec<OrderedListState<T>> spec,
 Coder<T> elemCoder)

bindMultimap

<KeyT,
ValueT> MultimapState<KeyT,ValueT> bindMultimap(String id,
 StateSpec<MultimapState<KeyT,ValueT>> spec,
 Coder<KeyT> keyCoder,
 Coder<ValueT> valueCoder)

bindCombining

<InputT,
AccumT,
OutputT>
CombiningState<InputT,AccumT,OutputT> bindCombining(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(String id,
 StateSpec<CombiningState<InputT,AccumT,OutputT>> spec,
 Coder<AccumT> accumCoder,
 CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> combineFn)

bindWatermark

WatermarkHoldState bindWatermark(String id,
 StateSpec<WatermarkHoldState> spec,
 TimestampCombiner timestampCombiner)

Bind to a watermark StateSpec.

This accepts the TimestampCombiner that dictates how watermark hold timestamps added to the returned WatermarkHoldState are to be combined.