org.apache.beam.sdk.state

Interface StateBinder

@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 and 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> 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 watermark StateSpec.

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)

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 watermark StateSpec.

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