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 org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT> & org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>>	Wraps an existing operator so it can be bootstrapped.
StateBootstrapWrapperOperatorFactory<IN,OUT,OP extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT> & org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>,OPF extends org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<IN,OUT>>	StreamOperatorFactory for StateBootstrapWrapperOperator.