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

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

Package	Description
org.apache.flink.cep.operator
org.apache.flink.streaming.api
org.apache.flink.streaming.api.collector.selector
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.functions.windowing
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.co
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.connectors.cassandra
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.internals
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.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.

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

Class and Description
AbstractStreamOperator Base class for all stream operators.
AbstractUdfStreamOperator This is used as the base class for operators that have a user-defined function.
InternalTimer Internal interface for in-flight timers.
KeyContext Inteface for setting and querying the current key of keyed operations.
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.
OutputTypeConfigurable Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
StreamOperator Basic interface for stream operators.
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

Class and Description
InternalTimerService Interface for working with time and timers.

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

Class and Description
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.

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

Class and Description
OneInputStreamOperator Interface for stream operators with one input.
StreamSink A StreamOperator for executing SinkFunctions.
StreamSource StreamOperator for streaming sources.
TwoInputStreamOperator Interface for stream operators with two inputs.

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

Class and Description
AbstractStreamOperator Base class for all stream operators.
KeyContext Inteface for setting and querying the current key of keyed operations.
OneInputStreamOperator Interface for stream operators with one input.
StreamOperator Basic interface for stream operators.

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

Class and Description
AbstractStreamOperator Base class for all stream operators.
KeyContext Inteface for setting and querying the current key of keyed operations.
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.
StreamOperator Basic interface for stream operators.

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

Class and Description
OutputTypeConfigurable Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.

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

Class and Description
StreamOperator Basic interface for stream operators.
TwoInputStreamOperator Interface for stream operators with two inputs.

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

Class and Description
AbstractStreamOperator Base class for all stream operators.
AbstractUdfStreamOperator This is used as the base class for operators that have a user-defined function.
ChainingStrategy Defines the chaining scheme for the operator.
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 available to all operators extending the AbstractStreamOperator.
KeyContext Inteface for setting and querying the current key of keyed operations.
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.
OutputTypeConfigurable Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
StreamingRuntimeContext Implementation of the RuntimeContext, for streaming operators.
StreamOperator 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.
StreamSource StreamOperator for streaming sources.
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.

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

Class and Description
AbstractStreamOperator Base class for all stream operators.
AbstractUdfStreamOperator This is used as the base class for operators that have a user-defined function.
KeyContext Inteface for setting and querying the current key of keyed operations.
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.
OutputTypeConfigurable Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
StreamOperator Basic interface for stream operators.

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

Class and Description
AbstractStreamOperator Base class for all stream operators.
AbstractUdfStreamOperator This is used as the base class for operators that have a user-defined function.
InternalTimer Internal interface for in-flight timers.
KeyContext Inteface for setting and querying the current key of keyed operations.
OutputTypeConfigurable Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
StreamOperator Basic interface for stream operators.
TimestampedCollector Wrapper around an Output for user functions that expect a Collector.
Triggerable Interface for things that can be called by InternalTimerService.
TwoInputStreamOperator Interface for stream operators with two inputs.

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

Class and Description
ChainingStrategy Defines the chaining scheme for the operator.
OneInputStreamOperator Interface for stream operators with one input.
StreamSink A StreamOperator for executing SinkFunctions.
StreamSource StreamOperator for streaming sources.
TwoInputStreamOperator Interface for stream operators with two inputs.

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

Class and Description
AbstractStreamOperator Base class for all stream operators.
KeyContext Inteface for setting and querying the current key of keyed operations.
OneInputStreamOperator Interface for stream operators with one input.
StreamOperator Basic interface for stream operators.

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

Class and Description
StreamingRuntimeContext Implementation of the RuntimeContext, for streaming operators.

Classes in org.apache.flink.streaming.api.operators used by org.apache.flink.streaming.connectors.kafka.internals

Class and Description
StreamingRuntimeContext Implementation of the RuntimeContext, for streaming operators.

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

Class and Description
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.
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 and Description
AbstractStreamOperator Base class for all stream operators.
AbstractUdfStreamOperator This is used as the base class for operators that have a user-defined function.
KeyContext Inteface for setting and querying the current key of keyed operations.
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.
StreamOperator Basic interface for stream operators.

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

Class and Description
AbstractStreamOperator Base class for all stream operators.
AbstractUdfStreamOperator This is used as the base class for operators that have a user-defined function.
InternalTimer Internal interface for in-flight timers.
InternalTimerService Interface for working with time and timers.
KeyContext Inteface for setting and querying the current key of keyed operations.
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.
StreamOperator Basic interface for stream operators.
TimestampedCollector Wrapper around an Output for user functions that expect a Collector.
Triggerable Interface for things that can be called by InternalTimerService.

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

Class and Description
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.
StreamOperator Basic interface for stream operators.
StreamSource StreamOperator for streaming sources.
StreamTaskStateInitializer This is the interface through which stream task expose a StreamOperatorStateContext to their operators.