com.google.cloud.dataflow.sdk.util.state

Interface StateTag.StateBinder

Enclosing interface:

StateTag<StateT extends State>

public static interface StateTag.StateBinder

Visitor for binding a StateTag and to the associated State.

Method Summary

Modifier and Type	Method and Description
<T> BagState<T>	bindBag(StateTag<BagState<T>> address, Coder<T> elemCoder)
<InputT,AccumT,OutputT> CombiningValueStateInternal<InputT,AccumT,OutputT>	bindCombiningValue(StateTag<CombiningValueStateInternal<InputT,AccumT,OutputT>> address, Coder<AccumT> accumCoder, Combine.CombineFn<InputT,AccumT,OutputT> combineFn)
<T> ValueState<T>	bindValue(StateTag<ValueState<T>> address, Coder<T> coder)
<T> WatermarkStateInternal	bindWatermark(StateTag<WatermarkStateInternal> address)

Method Detail

bindValue

<T> ValueState<T> bindValue(StateTag<ValueState<T>> address,
                            Coder<T> coder)

bindBag

<T> BagState<T> bindBag(StateTag<BagState<T>> address,
                        Coder<T> elemCoder)

bindCombiningValue

<InputT,AccumT,OutputT> CombiningValueStateInternal<InputT,AccumT,OutputT> bindCombiningValue(StateTag<CombiningValueStateInternal<InputT,AccumT,OutputT>> address,
                                                                                              Coder<AccumT> accumCoder,
                                                                                              Combine.CombineFn<InputT,AccumT,OutputT> combineFn)

bindWatermark

<T> WatermarkStateInternal bindWatermark(StateTag<WatermarkStateInternal> address)