Package org.apache.flink.state.api.output.operators

Class Summary

Class	Description
BroadcastStateBootstrapOperator<IN>	A StreamOperator for executing BroadcastStateBootstrapFunction's.
GroupReduceOperator<IN,OUT>	An operator for executing a GroupReduceFunction on a bounded DataStream.
KeyedStateBootstrapOperator<K,IN>	A StreamOperator for executing KeyedStateBootstrapFunction's.
LazyTimerService	A timer service that initializes its internal timer service lazily.
StateBootstrapOperator<IN>	A StreamOperator for executing StateBootstrapFunction's.
StateBootstrapWrapperOperator<IN,OUT,OP extends AbstractStreamOperator<OUT> & OneInputStreamOperator<IN,OUT>>	Wraps an existing operator so it can be bootstrapped.