Package org.apache.flink.streaming.api.operators

Interface Summary

Interface	Description
InternalTimer<K,N>	Internal interface for in-flight timers.
InternalTimerService<N>	Interface for working with time and timers.
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReader<K,N>	A reader for a InternalTimersSnapshot.
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotWriter	A writer for a InternalTimersSnapshot.
KeyContext	Inteface for setting and querying the current key of keyed operations.
OneInputStreamOperator<IN,OUT>	Interface for stream operators with one input.
OnWatermarkCallback<KEY>	A callback registered with the InternalWatermarkCallbackService service.
Output<T>	A StreamOperator is supplied with an object of this interface that can be used to emit elements and other messages, such as barriers and watermarks, from an operator.
OutputTypeConfigurable<OUT>	Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
StreamOperator<OUT>	Basic interface for stream operators.
StreamOperatorStateContext	This interface represents a context from which a stream operator can initialize everything connected to state such as e.g.
StreamTaskStateInitializer	This is the interface through which stream task expose a StreamOperatorStateContext to their operators.
Triggerable<K,N>	Interface for things that can be called by InternalTimerService.
TwoInputStreamOperator<IN1,IN2,OUT>	Interface for stream operators with two inputs.

Class Summary

Class	Description
AbstractStreamOperator<OUT>	Base class for all stream operators.
AbstractStreamOperator.CountingOutput<OUT>	Wrapping Output that updates metrics on the number of emitted elements.
AbstractUdfStreamOperator<OUT,F extends org.apache.flink.api.common.functions.Function>	This is used as the base class for operators that have a user-defined function.
BackendRestorerProcedure<T extends Closeable & org.apache.flink.util.Disposable & org.apache.flink.runtime.state.Snapshotable<?,Collection<S>>,S extends org.apache.flink.runtime.state.StateObject>	This class implements the logic that creates (and potentially restores) a state backend.
InternalTimerServiceImpl<K,N>	InternalTimerService that stores timers on the Java heap.
InternalTimerServiceSerializationProxy<K>	Serialization proxy for the timer services for a given key-group.
InternalTimersSnapshot<K,N>	A snapshot of internal timers, containing event and processing timers and the serializers to use to write / read them.
InternalTimersSnapshotReaderWriters	Readers and writers for different versions of the InternalTimersSnapshot.
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer<K,N>	A TypeSerializer used to serialize/deserialize a TimerHeapInternalTimer.
InternalTimeServiceManager<K>	An entity keeping all the time-related services available to all operators extending the AbstractStreamOperator.
KeyedProcessOperator<K,IN,OUT>	A StreamOperator for executing KeyedProcessFunctions.
LegacyKeyedProcessOperator<K,IN,OUT>	Deprecated Replaced by KeyedProcessOperator which takes KeyedProcessFunction
OperatorSnapshotFinalizer	This class finalizes OperatorSnapshotFutures.
OperatorSnapshotFutures	Result of StreamOperator.snapshotState(long, long, org.apache.flink.runtime.checkpoint.CheckpointOptions, org.apache.flink.runtime.state.CheckpointStreamFactory).
ProcessOperator<IN,OUT>	A StreamOperator for executing ProcessFunctions.
StoppableStreamSource<OUT,SRC extends SourceFunction<OUT> & org.apache.flink.api.common.functions.StoppableFunction>	StoppableStreamSource takes a SourceFunction that implements StoppableFunction.
StreamFilter<IN>	A StreamOperator for executing FilterFunctions.
StreamFlatMap<IN,OUT>	A StreamOperator for executing FlatMapFunctions.
StreamGroupedFold<IN,OUT,KEY>	Deprecated will be removed in a future version
StreamGroupedReduce<IN>	A StreamOperator for executing a ReduceFunction on a KeyedStream.
StreamingRuntimeContext	Implementation of the RuntimeContext, for streaming operators.
StreamMap<IN,OUT>	A StreamOperator for executing MapFunctions.
StreamProject<IN,OUT extends org.apache.flink.api.java.tuple.Tuple>	A StreamOperator for executing projections on streams.
StreamSink<IN>	A StreamOperator for executing SinkFunctions.
StreamSource<OUT,SRC extends SourceFunction<OUT>>	StreamOperator for streaming sources.
StreamSourceContexts	Source contexts for various stream time characteristics.
StreamTaskStateInitializerImpl	This class is the main implementation of a StreamTaskStateInitializer.
TimerHeapInternalTimer<K,N>	Implementation of InternalTimer to use with a HeapPriorityQueueSet.
TimerSerializer<K,N>	A serializer for TimerHeapInternalTimer objects that produces a serialization format that is lexicographically aligned the priority of the timers.
TimerSerializer.TimerSerializerConfigSnapshot<K,N>	Snaphot of a TimerSerializer.
TimestampedCollector<T>	Wrapper around an Output for user functions that expect a Collector.

Enum Summary

Enum	Description
ChainingStrategy	Defines the chaining scheme for the operator.