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

Packages that use org.apache.flink.streaming.api.operators

Package	Description
org.apache.flink.streaming.api
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.query
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.async.queue
org.apache.flink.streaming.api.operators.co
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.api.operators.sort
org.apache.flink.streaming.api.operators.sorted.state
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.operators	This package contains the operators that perform the stream transformations.
org.apache.flink.streaming.runtime.operators.sink
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.runtime.translators

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api

Class	Description
InternalTimerService	Interface for working with time and timers.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.datastream

Class	Description
OneInputStreamOperator	Interface for stream operators with one input.
OneInputStreamOperatorFactory	A factory to create OneInputStreamOperator.
StreamOperatorFactory	A factory to create StreamOperator.
StreamSource	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
TwoInputStreamOperator	Interface for stream operators with two inputs.
TwoInputStreamOperatorFactory	A factory to create TwoInputStreamOperator.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.functions.query

Class	Description
AbstractStreamOperator	Base class for all stream operators.
Input	Input interface used in MultipleInputStreamOperator.
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<?>).
OneInputStreamOperator	Interface for stream operators with one input.
SetupableStreamOperator	Deprecated. This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.
StreamOperator	Basic interface for stream operators.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.functions.source

Class	Description
AbstractStreamOperator	Base class for all stream operators.
AbstractStreamOperatorFactory	Base class for all stream operator factories.
Input	Input interface used in MultipleInputStreamOperator.
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<?>).
OneInputStreamOperator	Interface for stream operators with one input.
OneInputStreamOperatorFactory	A factory to create OneInputStreamOperator.
OutputTypeConfigurable	Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
SetupableStreamOperator	Deprecated. This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.
StreamOperator	Basic interface for stream operators.
StreamOperatorFactory	A factory to create StreamOperator.
StreamOperatorParameters	Helper class to construct AbstractStreamOperatorV2.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.
YieldingOperatorFactory	An operator that needs access to the MailboxExecutor to yield to downstream operators needs to be created through a factory implementing this interface.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.graph

Class	Description
InternalTimeServiceManager.Provider	A provider pattern for creating an instance of a InternalTimeServiceManager.
SourceOperatorFactory	The Factory class for SourceOperator.
StreamOperator	Basic interface for stream operators.
StreamOperatorFactory	A factory to create StreamOperator.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.operators

Class	Description
AbstractStreamOperator	Base class for all stream operators.
AbstractStreamOperatorFactory	Base class for all stream operator factories.
AbstractStreamOperatorV2	New base class for all stream operators, intended to eventually replace AbstractStreamOperator.
AbstractUdfStreamOperator	This is used as the base class for operators that have a user-defined function.
ChainingStrategy	Defines the chaining scheme for the operator.
CoordinatedOperatorFactory	A factory class for the StreamOperators implementing OperatorEventHandler.
Input	Input interface used in MultipleInputStreamOperator.
InputFormatOperatorFactory	Input format source operator factory.
InputSelection	Describe the input selection that stream operators want to read records.
InputSelection.Builder	Utility class for creating InputSelection.
InternalTimer	Internal interface for in-flight timers.
InternalTimerService	Interface for working with time and timers.
InternalTimersSnapshot	A snapshot of internal timers, containing event and processing timers and the serializers to use to write / read them.
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReader	A reader for a InternalTimersSnapshot.
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotWriter	A writer for a InternalTimersSnapshot.
InternalTimeServiceManager	An entity keeping all the time-related services.
InternalTimeServiceManager.Provider	A provider pattern for creating an instance of a InternalTimeServiceManager.
InternalTimeServiceManagerImpl	An entity keeping all the time-related services.
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<?>).
OneInputStreamOperator	Interface for stream operators with one input.
OperatorSnapshotFutures	Result of StreamOperator.snapshotState(long, long, org.apache.flink.runtime.checkpoint.CheckpointOptions, org.apache.flink.runtime.state.CheckpointStreamFactory).
Output	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	Interface for operator factories which create the sink operator containing an OutputFormat.
OutputTypeConfigurable	Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
SetupableStreamOperator	Deprecated. This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.
SimpleOperatorFactory	Simple factory which just wrap existed StreamOperator.
StreamingRuntimeContext	Implementation of the RuntimeContext, for streaming operators.
StreamOperator	Basic interface for stream operators.
StreamOperatorFactory	A factory to create StreamOperator.
StreamOperatorParameters	Helper class to construct AbstractStreamOperatorV2.
StreamOperatorStateContext	This interface represents a context from which a stream operator can initialize everything connected to state such as e.g.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.
StreamSource	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
StreamTaskStateInitializer	This is the interface through which stream task expose a StreamOperatorStateContext to their operators.
TimerHeapInternalTimer	Implementation of InternalTimer to use with a HeapPriorityQueueSet.
TimerSerializer	A serializer for TimerHeapInternalTimer objects that produces a serialization format that is lexicographically aligned the priority of the timers.
TimerSerializerSnapshot	Snapshot class for the TimerSerializer.
Triggerable	Interface for things that can be called by InternalTimerService.
UdfStreamOperatorFactory	Udf stream operator factory.
UserFunctionProvider	The interface with user function.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.operators.async

Class	Description
AbstractStreamOperator	Base class for all stream operators.
AbstractStreamOperatorFactory	Base class for all stream operator factories.
AbstractUdfStreamOperator	This is used as the base class for operators that have a user-defined function.
BoundedOneInput	Interface for one-input operators that need to be notified about the logical/semantical end of input.
Input	Input interface used in MultipleInputStreamOperator.
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<?>).
OneInputStreamOperator	Interface for stream operators with one input.
OneInputStreamOperatorFactory	A factory to create OneInputStreamOperator.
Output	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	Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
SetupableStreamOperator	Deprecated. This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.
StreamOperator	Basic interface for stream operators.
StreamOperatorFactory	A factory to create StreamOperator.
StreamOperatorParameters	Helper class to construct AbstractStreamOperatorV2.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.
UserFunctionProvider	The interface with user function.
YieldingOperatorFactory	An operator that needs access to the MailboxExecutor to yield to downstream operators needs to be created through a factory implementing this interface.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.operators.async.queue

Class	Description
TimestampedCollector	Wrapper around an Output for user functions that expect a Output.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.operators.co

Class	Description
AbstractStreamOperator	Base class for all stream operators.
AbstractUdfStreamOperator	This is used as the base class for operators that have a user-defined function.
BoundedMultiInput	Interface for multi-input operators that need to be notified about the logical/semantical end of input.
InputSelectable	Interface for stream operators that can select the input to get StreamRecord.
InputSelection	Describe the input selection that stream operators want to read records.
InternalTimer	Internal interface for in-flight timers.
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<?>).
OutputTypeConfigurable	Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
SetupableStreamOperator	Deprecated. This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.
StreamOperator	Basic interface for stream operators.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.
TimestampedCollector	Wrapper around an Output for user functions that expect a Output.
Triggerable	Interface for things that can be called by InternalTimerService.
TwoInputStreamOperator	Interface for stream operators with two inputs.
UserFunctionProvider	The interface with user function.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.operators.collect

Class	Description
AbstractStreamOperator	Base class for all stream operators.
AbstractStreamOperatorFactory	Base class for all stream operator factories.
AbstractUdfStreamOperator	This is used as the base class for operators that have a user-defined function.
CoordinatedOperatorFactory	A factory class for the StreamOperators implementing OperatorEventHandler.
Input	Input interface used in MultipleInputStreamOperator.
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<?>).
OneInputStreamOperator	Interface for stream operators with one input.
OutputTypeConfigurable	Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
SetupableStreamOperator	Deprecated. This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.
SimpleOperatorFactory	Simple factory which just wrap existed StreamOperator.
SimpleUdfStreamOperatorFactory	Udf stream operator factory which just wrap existed AbstractUdfStreamOperator.
StreamOperator	Basic interface for stream operators.
StreamOperatorFactory	A factory to create StreamOperator.
StreamOperatorParameters	Helper class to construct AbstractStreamOperatorV2.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.
StreamSink	A StreamOperator for executing SinkFunctions.
UdfStreamOperatorFactory	Udf stream operator factory.
UserFunctionProvider	The interface with user function.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.operators.sort

Class	Description
InputSelectable	Interface for stream operators that can select the input to get StreamRecord.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.operators.sorted.state

Class	Description
InternalTimerService	Interface for working with time and timers.
InternalTimeServiceManager	An entity keeping all the time-related services.
KeyContext	Interface for setting and querying the current key of keyed operations.
Triggerable	Interface for things that can be called by InternalTimerService.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.api.transformations

Class	Description
ChainingStrategy	Defines the chaining scheme for the operator.
OneInputStreamOperator	Interface for stream operators with one input.
StreamOperatorFactory	A factory to create StreamOperator.
StreamSink	A StreamOperator for executing SinkFunctions.
StreamSource	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
TwoInputStreamOperator	Interface for stream operators with two inputs.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.runtime.io

Class	Description
BoundedMultiInput	Interface for multi-input operators that need to be notified about the logical/semantical end of input.
Input	Input interface used in MultipleInputStreamOperator.
InputSelectable	Interface for stream operators that can select the input to get StreamRecord.
MultipleInputStreamOperator	Interface for stream operators with multiple Inputs.
Output	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.
SourceOperator	Base source operator only used for integrating the source reader which is proposed by FLIP-27.
TwoInputStreamOperator	Interface for stream operators with two inputs.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.runtime.operators

Class	Description
AbstractStreamOperator	Base class for all stream operators.
Input	Input interface used in MultipleInputStreamOperator.
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<?>).
OneInputStreamOperator	Interface for stream operators with one input.
Output	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.
SetupableStreamOperator	Deprecated. This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.
StreamOperator	Basic interface for stream operators.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.runtime.operators.sink

Class	Description
AbstractStreamOperatorFactory	Base class for all stream operator factories.
OneInputStreamOperatorFactory	A factory to create OneInputStreamOperator.
StreamOperator	Basic interface for stream operators.
StreamOperatorFactory	A factory to create StreamOperator.
StreamOperatorParameters	Helper class to construct AbstractStreamOperatorV2.
YieldingOperatorFactory	An operator that needs access to the MailboxExecutor to yield to downstream operators needs to be created through a factory implementing this interface.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.runtime.operators.windowing

Class	Description
AbstractStreamOperator	Base class for all stream operators.
AbstractUdfStreamOperator	This is used as the base class for operators that have a user-defined function.
Input	Input interface used in MultipleInputStreamOperator.
InternalTimer	Internal interface for in-flight timers.
InternalTimerService	Interface for working with time and timers.
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<?>).
OneInputStreamOperator	Interface for stream operators with one input.
OutputTypeConfigurable	Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
SetupableStreamOperator	Deprecated. This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.
StreamOperator	Basic interface for stream operators.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.
TimestampedCollector	Wrapper around an Output for user functions that expect a Output.
Triggerable	Interface for things that can be called by InternalTimerService.
UserFunctionProvider	The interface with user function.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.runtime.tasks

Class	Description
BoundedMultiInput	Interface for multi-input operators that need to be notified about the logical/semantical end of input.
Input	Input interface used in MultipleInputStreamOperator.
OperatorSnapshotFutures	Result of StreamOperator.snapshotState(long, long, org.apache.flink.runtime.checkpoint.CheckpointOptions, org.apache.flink.runtime.state.CheckpointStreamFactory).
Output	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.
SourceOperator	Base source operator only used for integrating the source reader which is proposed by FLIP-27.
StreamOperator	Basic interface for stream operators.
StreamSource	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
StreamTaskStateInitializer	This is the interface through which stream task expose a StreamOperatorStateContext to their operators.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.runtime.translators

Class	Description
AbstractStreamOperator	Base class for all stream operators.
Input	Input interface used in MultipleInputStreamOperator.
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<?>).
OneInputStreamOperator	Interface for stream operators with one input.
SetupableStreamOperator	Deprecated. This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.
StreamOperator	Basic interface for stream operators.
StreamOperatorFactory	A factory to create StreamOperator.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.