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

Interface Summary

Interface	Description
BoundedMultiInput	Interface for multi-input operators that need to be notified about the logical/semantical end of input.
BoundedOneInput	Interface for one-input operators that need to be notified about the logical/semantical end of input.
CoordinatedOperatorFactory<OUT>	A factory class for the StreamOperators implementing OperatorEventHandler.
Input<IN>	Input interface used in MultipleInputStreamOperator.
InputFormatOperatorFactory<OUT>	Input format source operator factory.
InputSelectable	Interface for stream operators that can select the input to get StreamRecord.
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.
InternalTimeServiceManager<K>	An entity keeping all the time-related services.
InternalTimeServiceManager.Provider	A provider pattern for creating an instance of a InternalTimeServiceManager.
InternalTimeServiceManager.ShouldStopAdvancingFn	Signals whether the watermark should continue advancing.
KeyContext	Interface for setting and querying the current key of keyed operations.
KeyContextHandler	This interface is used to optimize the calls of Input.setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN>), StreamOperator.setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) and StreamOperator.setKeyContextElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>).
MultipleInputStreamOperator<OUT>	Interface for stream operators with multiple Inputs.
OneInputStreamOperator<IN,OUT>	Interface for stream operators with one input.
OneInputStreamOperatorFactory<IN,OUT>	A factory to create OneInputStreamOperator.
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.
OutputFormatOperatorFactory<IN,OUT>	Interface for operator factories which create the sink operator containing an OutputFormat.
OutputTypeConfigurable<OUT>	Stream operators can implement this interface if they need access to the output type information at org.apache.flink.streaming.api.graph.StreamGraph generation.
StreamOperator<OUT>	Basic interface for stream operators.
StreamOperatorFactory<OUT>	A factory to create StreamOperator.
StreamOperatorStateContext	This interface represents a context from which a stream operator can initialize everything connected to state such as e.g. backends, raw state, and timer service manager.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.
StreamTaskStateInitializer	This is the interface through which stream task expose a StreamOperatorStateContext to their operators.
StreamTaskStateInitializerImpl.KeyedStateBackendCreator<K,R extends Disposable & Closeable>	Functional interface to create the keyed state backend.
Triggerable<K,N>	Interface for things that can be called by InternalTimerService.
TwoInputStreamOperator<IN1,IN2,OUT>	Interface for stream operators with two inputs.
TwoInputStreamOperatorFactory<IN1,IN2,OUT>	A factory to create TwoInputStreamOperator.
UdfStreamOperatorFactory<OUT>	Udf stream operator factory.
UserFunctionProvider<F extends Function>	The interface with user function.
YieldingOperator<OUT>	A V1 operator that needs access to the MailboxExecutor should implement this interface.

Class Summary

Class	Description
AbstractInput<IN,OUT>	Base abstract implementation of Input interface intended to be used when extending AbstractStreamOperatorV2.
AbstractStreamOperator<OUT>	Base class for all stream operators.
AbstractStreamOperatorFactory<OUT>	Base class for all stream operator factories.
AbstractStreamOperatorV2<OUT>	New base class for all stream operators, intended to eventually replace AbstractStreamOperator.
AbstractUdfStreamOperator<OUT,F extends Function>	This is used as the base class for operators that have a user-defined function.
BackendRestorerProcedure<T extends Closeable & Disposable,S extends StateObject>	This class implements the logic that creates (and potentially restores) a state backend.
BatchGroupedReduceOperator<IN,KEY>	A StreamOperator for executing a ReduceFunction on a KeyedStream in a RuntimeExecutionMode.BATCH mode.
CountingOutput<OUT>	Wrapping Output that updates metrics on the number of emitted elements.
InputSelection	Describe the input selection that stream operators want to read records.
InputSelection.Builder	Utility class for creating InputSelection.
InternalTimerServiceAsyncImpl<K,N>	An implementation of InternalTimerService that is used by org.apache.flink.streaming.runtime.operators.asyncprocessing.AbstractAsyncStateStreamOperator.
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.
InternalTimeServiceManagerImpl<K>	An entity keeping all the time-related services.
KeyedProcessOperator<K,IN,OUT>	A StreamOperator for executing KeyedProcessFunctions.
LegacyKeyedProcessOperator<K,IN,OUT>	Deprecated. Replaced by KeyedProcessOperator which takes KeyedProcessFunction
MailboxWatermarkProcessor<OUT>	A helper class to let operators emit watermarks incrementally from mailbox.
MapPartitionIterator<IN>	The MapPartitionIterator is an iterator used in the MapPartitionOperator.The task main thread will add records to it.
MapPartitionOperator<IN,OUT>	The MapPartitionOperator is used to process all records in each partition on non-keyed stream.
OperatorAttributes	OperatorAttributes element provides Job Manager with information that can be used to optimize job performance.
OperatorAttributesBuilder	The builder class for OperatorAttributes.
OperatorSnapshotFinalizer	This class finalizes OperatorSnapshotFutures.
OperatorSnapshotFutures	Result of StreamOperator.snapshotState(long, long, org.apache.flink.runtime.checkpoint.CheckpointOptions, org.apache.flink.runtime.state.CheckpointStreamFactory).
PartitionAggregateOperator<IN,ACC,OUT>	The PartitionAggregateOperator is used to apply the aggregate transformation on all records of each partition.
PartitionReduceOperator<IN>	The PartitionReduceOperator is used to apply the reduce transformation on all records of each partition.
ProcessOperator<IN,OUT>	A StreamOperator for executing ProcessFunctions.
SimpleInputFormatOperatorFactory<OUT>	Input format source operator factory which just wrap existed StreamSource.
SimpleOperatorFactory<OUT>	Simple factory which just wrap existed StreamOperator.
SimpleOutputFormatOperatorFactory<IN,OUT>	A simple operator factory which create an operator containing an OutputFormat.
SimpleUdfStreamOperatorFactory<OUT>	Udf stream operator factory which just wrap existed AbstractUdfStreamOperator.
SourceOperator<OUT,SplitT extends SourceSplit>	Base source operator only used for integrating the source reader which is proposed by FLIP-27.
SourceOperatorFactory<OUT>	The Factory class for SourceOperator.
StreamFilter<IN>	A StreamOperator for executing FilterFunctions.
StreamFlatMap<IN,OUT>	A StreamOperator for executing FlatMapFunctions.
StreamGroupedReduceOperator<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.
StreamOperatorFactoryUtil	A utility to instantiate new operators with a given factory.
StreamOperatorParameters<OUT>	Helper class to construct AbstractStreamOperatorV2.
StreamOperatorStateHandler	Class encapsulating various state backend handling logic for StreamOperator implementations.
StreamOperatorUtils
StreamProject<IN,OUT extends Tuple>	A StreamOperator for executing projections on streams.
StreamSink<IN>	A StreamOperator for executing SinkFunctions.
StreamSource<OUT,SRC extends SourceFunction<OUT>>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
StreamSourceContexts	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
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.
TimerSerializerSnapshot<K,N>	Snapshot class for the TimerSerializer.
TimestampedCollector<T>	Wrapper around an Output for user functions that expect a Output.

Enum Summary

Enum	Description
ChainingStrategy	Defines the chaining scheme for the operator.