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