Package org.apache.beam.runners.flink.translation.wrappers.streaming.state

Class FlinkStateInternals.EarlyBinder

java.lang.Object

org.apache.beam.runners.flink.translation.wrappers.streaming.state.FlinkStateInternals.EarlyBinder

All Implemented Interfaces:

StateBinder

Enclosing class:

FlinkStateInternals<K>

public static class FlinkStateInternals.EarlyBinder
extends Object
implements StateBinder

Eagerly create user state to work around https://jira.apache.org/jira/browse/FLINK-12653.

Constructor Summary

Constructors

Constructor	Description
EarlyBinder(org.apache.flink.runtime.state.KeyedStateBackend keyedStateBackend, org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions, Coder<? extends BoundedWindow> windowCoder)

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EarlyBinder

public EarlyBinder(org.apache.flink.runtime.state.KeyedStateBackend keyedStateBackend,
 org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions,
 Coder<? extends BoundedWindow> windowCoder)

Method Details

bindValue

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

Specified by:

bindValue in interface StateBinder

bindBag

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

Specified by:

bindBag in interface StateBinder

bindSet

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

Specified by:

bindSet in interface StateBinder

bindMap

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

Specified by:

bindMap in interface StateBinder

bindOrderedList

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

Specified by:

bindOrderedList in interface StateBinder

bindMultimap

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

Specified by:

bindMultimap in interface StateBinder

bindCombining

public <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)

Specified by:

bindCombining in interface StateBinder

bindCombiningWithContext

public <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)

Specified by:

bindCombiningWithContext in interface StateBinder

bindWatermark

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

Description copied from interface: StateBinder

Bind to a watermark StateSpec.

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

Specified by:

bindWatermark in interface StateBinder