All Classes

Class	Description
AbstractBroadcastStateTransformation<IN1,IN2,OUT>	Base class for Broadcast State transformations.
AbstractCollectResultBuffer<T>	A buffer which encapsulates the logic of dealing with the response from the CollectSinkFunction.
AbstractDeserializationSchema<T>	Deprecated. Use AbstractDeserializationSchema instead.
AbstractInput<IN,OUT>	Base abstract implementation of Input interface intended to be used when extending AbstractStreamOperatorV2.
AbstractMultipleInputTransformation<OUT>	Base class for transformations representing the application of a MultipleInputStreamOperator to input Transformations.
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.
AbstractStreamTaskNetworkInput<T,R extends org.apache.flink.runtime.io.network.api.serialization.RecordDeserializer<org.apache.flink.runtime.plugable.DeserializationDelegate<StreamElement>>>	Base class for network-based StreamTaskInput where each channel has a designated RecordDeserializer for spanning records.
AbstractTwoInputStreamTask<IN1,IN2,OUT>	Abstract class for executing a TwoInputStreamOperator.
AbstractTwoInputTransformationTranslator<IN1,IN2,OUT,OP extends org.apache.flink.api.dag.Transformation<OUT>>	A base class with functionality used during translating transformations with two inputs.
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.
AggregateApplyAllWindowFunction<W extends Window,T,ACC,V,R>	A AllWindowFunction that composes an AggregateFunction and AllWindowFunction.
AggregateApplyWindowFunction<K,W extends Window,T,ACC,V,R>	A WindowFunction that composes an AggregateFunction and WindowFunction.
AggregationFunction<T>	Holder class for aggregation types that can be used on a windowed stream or keyed stream.
AggregationFunction.AggregationType	Aggregation types that can be used on a windowed stream or keyed stream.
AllWindowedStream<T,W extends Window>	A AllWindowedStream represents a data stream where the stream of elements is split into windows based on a WindowAssigner.
AllWindowFunction<IN,OUT,W extends Window>	Base interface for functions that are evaluated over non-keyed windows.
ArrayFromTuple	Converts a Tuple to an Object-Array.
AscendingTimestampExtractor<T>	Deprecated. Extend AscendingTimestampExtractor instead.
AscendingTimestampExtractor<T>	Deprecated.
AscendingTimestampExtractor.FailingHandler	Handler that fails the program when timestamp monotony is violated.
AscendingTimestampExtractor.IgnoringHandler	Handler that does nothing when timestamp monotony is violated.
AscendingTimestampExtractor.LoggingHandler	Handler that only logs violations of timestamp monotony, on WARN log level.
AscendingTimestampExtractor.MonotonyViolationHandler	Interface for handlers that handle violations of the monotonous ascending timestamps property.
AssignerWithPeriodicWatermarks<T>	Deprecated.
AssignerWithPeriodicWatermarksAdapter<T>	An adapter that wraps a AssignerWithPeriodicWatermarks into a WatermarkGenerator.
AssignerWithPeriodicWatermarksAdapter.Strategy<T>	A WatermarkStrategy that returns an AssignerWithPeriodicWatermarks wrapped as a WatermarkGenerator.
AssignerWithPunctuatedWatermarks<T>	Deprecated.
AssignerWithPunctuatedWatermarksAdapter<T>	An adapter that wraps a AssignerWithPunctuatedWatermarks into a WatermarkGenerator.
AssignerWithPunctuatedWatermarksAdapter.Strategy<T>	A WatermarkStrategy that returns an AssignerWithPunctuatedWatermarks wrapped as a WatermarkGenerator.
AsyncDataStream	A helper class to apply AsyncFunction to a data stream.
AsyncDataStream.OutputMode	Output mode for asynchronous operations.
AsyncFunction<IN,OUT>	A function to trigger Async I/O operation.
AsyncRetryPredicate<OUT>	Interface encapsulates an asynchronous retry predicate.
AsyncRetryStrategies	Utility class to create concrete AsyncRetryStrategy.
AsyncRetryStrategies.ExponentialBackoffDelayRetryStrategy<OUT>	ExponentialBackoffDelayRetryStrategy.
AsyncRetryStrategies.ExponentialBackoffDelayRetryStrategyBuilder<OUT>	ExponentialBackoffDelayRetryStrategyBuilder for building a ExponentialBackoffDelayRetryStrategy.
AsyncRetryStrategies.FixedDelayRetryStrategy<OUT>	FixedDelayRetryStrategy.
AsyncRetryStrategies.FixedDelayRetryStrategyBuilder<OUT>	FixedDelayRetryStrategyBuilder for building a FixedDelayRetryStrategy.
AsyncRetryStrategy<OUT>	Interface encapsulates an asynchronous retry strategy.
AsyncWaitOperator<IN,OUT>	The AsyncWaitOperator allows to asynchronously process incoming stream records.
AsyncWaitOperatorFactory<IN,OUT>	The factory of AsyncWaitOperator.
BackendRestorerProcedure<T extends Closeable & org.apache.flink.util.Disposable,S extends org.apache.flink.runtime.state.StateObject>	This class implements the logic that creates (and potentially restores) a state backend.
BarrierAlignmentUtil	Utility for barrier alignment.
BarrierAlignmentUtil.Cancellable	A handle to a delayed action which can be cancelled.
BarrierAlignmentUtil.DelayableTimer	It can register a task to be executed some time later.
BaseBroadcastProcessFunction	The base class containing the functionality available to all broadcast process function.
BatchCoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT>	A TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions in RuntimeExecutionMode.BATCH execution mode.
BatchCoBroadcastWithNonKeyedOperator<IN1,IN2,OUT>	A TwoInputStreamOperator for executing BroadcastProcessFunctions in RuntimeExecutionMode.BATCH execution mode.
BatchExecutionCheckpointStorage	A simple CheckpointStorage which is used in a BATCH style execution.
BatchExecutionInternalTimeService<K,N>	An implementation of a InternalTimerService that manages timers with a single active key at a time.
BatchExecutionInternalTimeServiceManager<K>	An implementation of a InternalTimeServiceManager that manages timers with a single active key at a time.
BatchExecutionKeyedStateBackend<K>	A CheckpointableKeyedStateBackend which keeps values for a single key at a time.
BatchExecutionStateBackend	A simple StateBackend which is used in a BATCH style execution.
BatchExecutionUtils	A utility class for applying sorting inputs.
BatchGroupedReduceOperator<IN,KEY>	A StreamOperator for executing a ReduceFunction on a KeyedStream in a RuntimeExecutionMode.BATCH mode.
BlockingQueueBroker	Broker for the BlockingQueue used in StreamIterationHead and StreamIterationTail for implementing feedback streams.
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.
BoundedOutOfOrdernessTimestampExtractor<T>	This is a AssignerWithPeriodicWatermarks used to emit Watermarks that lag behind the element with the maximum timestamp (in event time) seen so far by a fixed amount of time, t_late.
BroadcastConnectedStream<IN1,IN2>	A BroadcastConnectedStream represents the result of connecting a keyed or non-keyed stream, with a BroadcastStream with broadcast state(s).
BroadcastPartitioner<T>	Partitioner that selects all the output channels.
BroadcastProcessFunction<IN1,IN2,OUT>	A function to be applied to a BroadcastConnectedStream that connects BroadcastStream, i.e.
BroadcastStateTransformation<IN1,IN2,OUT>	A non-keyed AbstractBroadcastStateTransformation.
BroadcastStateTransformationTranslator<IN1,IN2,OUT>	A TransformationTranslator for the BroadcastStateTransformation.
BroadcastStream<T>	A BroadcastStream is a stream with broadcast state(s).
Bucket<IN,BucketID>	A bucket is the directory organization of the output of the StreamingFileSink.
BucketFactory<IN,BucketID>	A factory able to create buckets for the StreamingFileSink.
BucketLifeCycleListener<IN,BucketID>	Listener about the status of Bucket.
Buckets<IN,BucketID>	The manager of the different active buckets in the StreamingFileSink.
CachedDataStream<T>	CachedDataStream represents a DataStream whose intermediate result will be cached at the first time when it is computed.
CacheTransformation<T>	When in batch mode, the CacheTransformation represents the intermediate result of the upper stream should be cached when it is computed at the first time.
CacheTransformationTranslator<OUT,T extends CacheTransformation<OUT>>	Translator for CacheTransformationTranslator.
CacheTransformationTranslator.IdentityStreamOperator<T>	The CacheTransformationTranslator.IdentityStreamOperator acts as a dummy source to consume cached intermediate dataset.
CacheTransformationTranslator.NoOpStreamOperator<T>	The CacheTransformationTranslator.NoOpStreamOperator acts as a dummy sink so that the upstream can produce the intermediate dataset to be cached.
ChainingStrategy	Defines the chaining scheme for the operator.
CheckpointBarrierHandler	The CheckpointBarrierHandler reacts to checkpoint barrier arriving from the input channels.
CheckpointBarrierTracker	The CheckpointBarrierTracker keeps track of what checkpoint barriers have been received from which input channels.
CheckpointCommittableManager<CommT>	A CheckpointCommittableManager collects committables for one checkpoint across potentially multiple upstream subtasks.
CheckpointCommitter	This class is used to save information about which sink operator instance has committed checkpoints to a backend.
CheckpointConfig	Configuration that captures all checkpointing related settings.
CheckpointConfig.ExternalizedCheckpointCleanup	Cleanup behaviour for externalized checkpoints when the job is cancelled.
CheckpointedCollectResultBuffer<T>	A buffer which encapsulates the logic of dealing with the response from the CollectSinkFunction.
CheckpointedFunction	This is the core interface for stateful transformation functions, meaning functions that maintain state across individual stream records.
CheckpointedInputGate	The CheckpointedInputGate uses CheckpointBarrierHandler to handle incoming CheckpointBarrier from the InputGate.
CheckpointingMode	The checkpointing mode defines what consistency guarantees the system gives in the presence of failures.
ClientAndIterator<E>	A pair of an Iterator to receive results from a streaming application and a JobClient to interact with the program.
CoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT>	A TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions.
CoBroadcastWithNonKeyedOperator<IN1,IN2,OUT>	A TwoInputStreamOperator for executing BroadcastProcessFunctions.
CoFeedbackTransformation<F>	This represents a feedback point in a topology.
CoFlatMapFunction<IN1,IN2,OUT>	A CoFlatMapFunction implements a flat-map transformation over two connected streams.
CoGroupedStreams<T1,T2>	CoGroupedStreams represents two DataStreams that have been co-grouped.
CoGroupedStreams.TaggedUnion<T1,T2>	Internal class for implementing tagged union co-group.
CoGroupedStreams.UnionSerializer<T1,T2>	TypeSerializer for CoGroupedStreams.TaggedUnion.
CoGroupedStreams.UnionSerializerSnapshot<T1,T2>	The TypeSerializerSnapshot for the CoGroupedStreams.UnionSerializer.
CoGroupedStreams.WithWindow<T1,T2,KEY,W extends Window>	A co-group operation that has KeySelectors defined for both inputs as well as a WindowAssigner.
CollectCoordinationRequest	A CoordinationRequest from the client indicating that it wants a new batch of query results.
CollectCoordinationResponse	A CoordinationResponse from the coordinator containing the required batch or new results and other necessary information in serialized form.
CollectResultFetcher<T>	A fetcher which fetches query results from sink and provides exactly-once semantics.
CollectResultIterator<T>	An iterator which iterates through the results of a query job.
CollectSink<IN>	A specialized data sink to be used by DataStreamUtils.collect().
CollectSinkAddressEvent	An OperatorEvent that passes the socket server address in the sink to the coordinator.
CollectSinkFunction<IN>	A sink function that collects query results and sends them back to the client.
CollectSinkOperator<IN>	A StreamSink that collects query results and sends them back to the client.
CollectSinkOperatorCoordinator	OperatorCoordinator for CollectSinkFunction.
CollectSinkOperatorCoordinator.Provider	Provider for CollectSinkOperatorCoordinator.
CollectSinkOperatorFactory<IN>	The Factory class for CollectSinkOperator.
CollectStreamSink<T>	A DataStreamSink which is used to collect results of a data stream.
CoMapFunction<IN1,IN2,OUT>	A CoFlatMapFunction implements a map() transformation over two connected streams.
CommitRequestImpl<CommT>	Internal implementation to commit a specific committable and handle the response.
CommitRequestState	Internal state of a committable.
CommittableCollector<CommT>	This class is responsible to book-keep the committing progress across checkpoints and upstream subtasks.
CommittableCollectorSerializer<CommT>	The serializer for the CommittableCollector.
CommittableMessage<CommT>	The message send from SinkWriter to Committer.
CommittableMessageSerializer<CommT>	The serializer to serialize CommittableMessages in custom operators.
CommittableMessageTypeInfo<CommT>	The type information for the CommittableMessage to make it consumable from a DataStream.
CommittableSummary<CommT>	This class tracks the information about committables belonging to one checkpoint coming from one subtask.
CommittableWithLineage<CommT>	Provides metadata.
CommitterOperatorFactory<CommT>	A StreamOperatorFactory for CommitterOperator.
ComparableAggregator<T>	An AggregationFunction that computes values based on comparisons of Comparables.
Comparator	Internal comparator implementation, for use with ComparableAggregator.
ConcatenatedExtract<FROM,OVER,TO>	Combines two extractors which will be executed one after each other.
ConfigurableStreamPartitioner	Interface for StreamPartitioner which have to be configured with the maximum parallelism of the stream transformation.
ConnectedStreams<IN1,IN2>	ConnectedStreams represent two connected streams of (possibly) different data types.
ContainingTaskDetails	Details about the operator containing task (such as StreamTask).
ContinuousEventTimeTrigger<W extends Window>	A Trigger that continuously fires based on a given time interval.
ContinuousFileMonitoringFunction<OUT>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
ContinuousFileReaderOperator<OUT,T extends TimestampedInputSplit>	The operator that reads the splits received from the preceding ContinuousFileMonitoringFunction.
ContinuousFileReaderOperatorFactory<OUT,T extends TimestampedInputSplit>	ContinuousFileReaderOperator factory.
ContinuousProcessingTimeTrigger<W extends Window>	A Trigger that continuously fires based on a given time interval as measured by the clock of the machine on which the job is running.
CoordinatedOperatorFactory<OUT>	A factory class for the StreamOperators implementing OperatorEventHandler.
CoProcessFunction<IN1,IN2,OUT>	A function that processes elements of two streams and produces a single output one.
CoProcessOperator<IN1,IN2,OUT>	A StreamOperator for executing CoProcessFunctions.
CosineDistance<DATA>	This delta function calculates the cosine distance between two given vectors.
CoStreamFlatMap<IN1,IN2,OUT>	StreamOperator for processing CoFlatMapFunctions.
CoStreamMap<IN1,IN2,OUT>	StreamOperator for processing CoMapFunctions.
CountEvictor<W extends Window>	An Evictor that keeps up to a certain amount of elements.
CountingOutput<OUT>	Wrapping Output that updates metrics on the number of emitted elements.
CountTrigger<W extends Window>	A Trigger that fires once the count of elements in a pane reaches the given count.
CustomPartitionerWrapper<K,T>	Partitioner that selects the channel with a user defined partitioner function on a key.
CustomSinkOperatorUidHashes	This class is responsible to hold operator Uid hashes from the common operators of the sink.
CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder	Builder to construct CustomSinkOperatorUidHashes.
DataGenerator<T>	Stateful and re-scalable data generator.
DataGeneratorSource<T>	Deprecated. Use org.apache.flink.connector.datagen.source.DataGeneratorSource instead.
DataInputStatus	It is an internal equivalent of InputStatus that provides additional non public statuses.
DataStream<T>	A DataStream represents a stream of elements of the same type.
DataStream.Collector<T>	This class acts as an accessor to elements collected via DataStream.collectAsync(Collector).
DataStreamSink<T>	A Stream Sink.
DataStreamSource<T>	The DataStreamSource represents the starting point of a DataStream.
DataStreamUtils	A collection of utilities for DataStreams.
DefaultBucketFactoryImpl<IN,BucketID>	A factory returning buckets.
DeltaEvictor<T,W extends Window>	An Evictor that keeps elements based on a DeltaFunction and a threshold.
DeltaFunction<DATA>	This interface allows the implementation of a function which calculates the delta between two data points.
DeltaTrigger<T,W extends Window>	A Trigger that fires based on a DeltaFunction and a threshold.
DeserializationSchema<T>	Deprecated. Use DeserializationSchema instead.
DiscardingSink<T>	A stream sink that ignores all elements.
DiscardingSink<IN>	A special sink that ignores all elements.
DynamicEventTimeSessionWindows<T>	A WindowAssigner that windows elements into sessions based on the timestamp of the elements.
DynamicProcessingTimeSessionWindows<T>	A WindowAssigner that windows elements into sessions based on the current processing time.
EuclideanDistance<DATA>	This delta function calculates the euclidean distance between two given points.
EventTimeSessionWindows	A WindowAssigner that windows elements into sessions based on the timestamp of the elements.
EventTimeTrigger	A Trigger that fires once the watermark passes the end of the window to which a pane belongs.
EvictingWindowOperator<K,IN,OUT,W extends Window>	A WindowOperator that also allows an Evictor to be used.
Evictor<T,W extends Window>	An Evictor can remove elements from a pane before/after the evaluation of WindowFunction and after the window evaluation gets triggered by a Trigger
Evictor.EvictorContext	A context object that is given to Evictor methods.
ExceptionInChainedOperatorException	A special exception that signifies that the cause exception came from a chained operator.
ExecutionCheckpointingOptions	Execution ConfigOption for configuring checkpointing related parameters.
ExternallyInducedSource<T,CD>	Deprecated. This interface is based on the SourceFunction API, which is due to be removed.
ExternallyInducedSource.CheckpointTrigger	Through the CheckpointTrigger, the source function notifies the Flink source operator when to trigger the checkpoint.
ExtractionAwareDeltaFunction<DATA,TO>	Extend this abstract class to implement a delta function which is aware of extracting the data on which the delta is calculated from a more complex data structure.
Extractor<FROM,TO>	Extractors allow to extract/convert one type to another.
FeedbackTransformation<T>	This represents a feedback point in a topology.
FieldAccessor<T,F>	These classes encapsulate the logic of accessing a field specified by the user as either an index or a field expression string.
FieldAccessorFactory	Static factories for the FieldAccessor utilities.
FieldFromArray<OUT>	Extracts a single field out of an array.
FieldFromTuple<OUT>	Extracts a single field out of a tuple.
FieldsFromArray<OUT>	Extracts multiple fields from an array and puts them into a new array of the specified type.
FieldsFromTuple	Extracts one or more fields of the type Double from a tuple and puts them into a new double[].
FileLifeCycleListener<BucketID>	Listener about the status of file.
FileMonitoringFunction	Deprecated. Internal class deprecated in favour of ContinuousFileMonitoringFunction.
FileMonitoringFunction.WatchType	The watch type of the FileMonitoringFunction.
FileProcessingMode	The mode in which the ContinuousFileMonitoringFunction operates.
FileReadFunction	Deprecated. Internal class deprecated in favour of ContinuousFileMonitoringFunction.
FinishedDataOutput<IN>	An empty PushingAsyncDataInput.DataOutput which is used by StreamOneInputProcessor once an DataInputStatus.END_OF_DATA is received.
FinishedOnRestoreInput<IN>	A fake Input for finished on restore tasks.
FinishedOnRestoreMainOperatorOutput<OUT>	A fake main operator output that skips all the following operators for finished on restored tasks.
FinishedOperatorChain<OUT,OP extends StreamOperator<OUT>>	The OperatorChain that is used for restoring tasks that are TaskStateManager.isTaskDeployedAsFinished().
ForwardForConsecutiveHashPartitioner<T>	If there are multiple consecutive and the same hash shuffles, SQL planner will change them except the first one to use forward partitioner, so that these operators can be chained to reduce unnecessary shuffles.
ForwardForUnspecifiedPartitioner<T>	When the parallelism of both upstream and downstream is ExecutionConfig.PARALLELISM_DEFAULT and the edge's partitioner is not specified (partitioner==null), the edge's partitioner will be set to FORWARD by default(See StreamGraph.createActualEdge(java.lang.Integer, java.lang.Integer, int, org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<?>, org.apache.flink.util.OutputTag, org.apache.flink.streaming.api.transformations.StreamExchangeMode, org.apache.flink.runtime.jobgraph.IntermediateDataSetID) method for details).
ForwardPartitioner<T>	Partitioner that forwards elements only to the locally running downstream operation.
FromElementsFunction<T>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
FromIteratorFunction<T>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
FromSplittableIteratorFunction<T>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
GaugePeriodTimer	Implementation of PeriodTimer based on TimerGauge.
GenericWriteAheadSink<IN>	Generic Sink that emits its input elements into an arbitrary backend.
GlobalCommitterOperator<CommT,GlobalCommT>	Implements the GlobalCommitter.
GlobalCommitterTransform<CommT>	Transformation for global committer.
GlobalCommitterTransformationTranslator<CommT>	A TransformationTranslator for the GlobalCommitterOperator.
GlobalPartitioner<T>	Partitioner that sends all elements to the downstream operator with subtask ID=0.
GlobalStreamExchangeMode	This mode decides the default ResultPartitionType of job edges.
GlobalWindow	The default window into which all data is placed (via GlobalWindows).
GlobalWindow.Serializer	A TypeSerializer for GlobalWindow.
GlobalWindow.Serializer.GlobalWindowSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
GlobalWindows	A WindowAssigner that assigns all elements to the same GlobalWindow.
GlobalWindows.NeverTrigger	A trigger that never fires, as default Trigger for GlobalWindows.
HeapPriorityQueue<T extends org.apache.flink.streaming.runtime.watermarkstatus.HeapPriorityQueue.HeapPriorityQueueElement>	This class has similar functions with HeapPriorityQueue.
IngestionTimeExtractor<T>	Deprecated.
Input<IN>	Input interface used in MultipleInputStreamOperator.
InputFormatOperatorFactory<OUT>	Input format source operator factory.
InputFormatSourceFunction<OUT>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
InputGateUtil	Utility for dealing with input gates.
InputProcessorUtil	Utility for creating CheckpointedInputGate based on checkpoint mode for StreamOneInputProcessor.
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.
InputSelection.Builder	Utility class for creating InputSelection.
InternalAggregateProcessAllWindowFunction<T,ACC,V,R,W extends Window>	Internal window function for wrapping a ProcessAllWindowFunction that takes an Iterable and an AggregateFunction.
InternalAggregateProcessWindowFunction<T,ACC,V,R,K,W extends Window>	Internal window function for wrapping a ProcessWindowFunction that takes an Iterable and an AggregateFunction.
InternalIterableAllWindowFunction<IN,OUT,W extends Window>	Internal window function for wrapping an AllWindowFunction that takes an Iterable when the window state also is an Iterable.
InternalIterableProcessAllWindowFunction<IN,OUT,W extends Window>	Internal window function for wrapping a ProcessAllWindowFunction that takes an Iterable when the window state also is an Iterable.
InternalIterableProcessWindowFunction<IN,OUT,KEY,W extends Window>	Internal window function for wrapping a ProcessWindowFunction that takes an Iterable when the window state also is an Iterable.
InternalIterableWindowFunction<IN,OUT,KEY,W extends Window>	Internal window function for wrapping a WindowFunction that takes an Iterable when the window state also is an Iterable.
InternalProcessAllWindowContext<IN,OUT,W extends Window>	Internal reusable context wrapper.
InternalProcessApplyAllWindowContext<IN,OUT,W extends Window>	Internal reusable context wrapper.
InternalProcessApplyWindowContext<IN,OUT,KEY,W extends Window>	Internal reusable context wrapper.
InternalProcessWindowContext<IN,OUT,KEY,W extends Window>	Internal reusable context wrapper.
InternalSingleValueAllWindowFunction<IN,OUT,W extends Window>	Internal window function for wrapping an AllWindowFunction that takes an Iterable when the window state is a single value.
InternalSingleValueProcessAllWindowFunction<IN,OUT,W extends Window>	Internal window function for wrapping a ProcessAllWindowFunction that takes an Iterable when the window state is a single value.
InternalSingleValueProcessWindowFunction<IN,OUT,KEY,W extends Window>	Internal window function for wrapping a ProcessWindowFunction that takes an Iterable when the window state is a single value.
InternalSingleValueWindowFunction<IN,OUT,KEY,W extends Window>	Internal window function for wrapping a WindowFunction that takes an Iterable when the window state is a single value.
InternalTimer<K,N>	Internal interface for in-flight timers.
InternalTimerService<N>	Interface for working with time and timers.
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.InternalTimersSnapshotReader<K,N>	A reader for a InternalTimersSnapshot.
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotWriter	A writer for a InternalTimersSnapshot.
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer<K,N>	A TypeSerializer used to serialize/deserialize a TimerHeapInternalTimer.
InternalTimeServiceManager<K>	An entity keeping all the time-related services.
InternalTimeServiceManager.Provider	A provider pattern for creating an instance of a InternalTimeServiceManager.
InternalTimeServiceManagerImpl<K>	An entity keeping all the time-related services.
InternalWatermark	The Watermark that contains extra information to be used internally.
InternalWindowFunction<IN,OUT,KEY,W extends Window>	Internal interface for functions that are evaluated over keyed (grouped) windows.
InternalWindowFunction.InternalWindowContext	A context for InternalWindowFunction, similar to ProcessWindowFunction.Context but for internal use.
IntervalJoinOperator<K,T1,T2,OUT>	An operator to execute time-bounded stream inner joins.
IntervalJoinOperator.BufferEntry<T>	A container for elements put in the left/write buffer.
IntervalJoinOperator.BufferEntrySerializer<T>	A serializer for the IntervalJoinOperator.BufferEntry.
IntervalJoinOperator.BufferEntrySerializerSnapshot<T>	A TypeSerializerSnapshot for IntervalJoinOperator.BufferEntrySerializer.
IterativeStream<T>	Deprecated. This method is deprecated since Flink 1.19.
IterativeStream.ConnectedIterativeStreams<I,F>	Deprecated. This method is deprecated since Flink 1.19.
JoinedStreams<T1,T2>	JoinedStreams represents two DataStreams that have been joined.
JoinedStreams.WithWindow<T1,T2,KEY,W extends Window>	A join operation that has KeySelectors defined for both inputs as well as a WindowAssigner.
JSONGenerator	Helper class for generating a JSON representation from a StreamGraph.
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<?>).
KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT>	A function to be applied to a BroadcastConnectedStream that connects BroadcastStream, i.e.
KeyedBroadcastStateTransformation<KEY,IN1,IN2,OUT>	A keyed AbstractBroadcastStateTransformation.
KeyedBroadcastStateTransformationTranslator<KEY,IN1,IN2,OUT>	A TransformationTranslator for the KeyedBroadcastStateTransformation.
KeyedCoProcessFunction<K,IN1,IN2,OUT>	A function that processes elements of two keyed streams and produces a single output one.
KeyedCoProcessOperator<K,IN1,IN2,OUT>	A StreamOperator for executing keyed KeyedCoProcessFunction.
KeyedMultipleInputTransformation<OUT>	AbstractMultipleInputTransformation implementation for keyed streams.
KeyedProcessFunction<K,I,O>	A keyed function that processes elements of a stream.
KeyedProcessOperator<K,IN,OUT>	A StreamOperator for executing KeyedProcessFunctions.
KeyedStream<T,KEY>	A KeyedStream represents a DataStream on which operator state is partitioned by key using a provided KeySelector.
KeyedStream.IntervalJoin<T1,T2,KEY>	Perform a join over a time interval.
KeyedStream.IntervalJoined<IN1,IN2,KEY>	IntervalJoined is a container for two streams that have keys for both sides as well as the time boundaries over which elements should be joined.
KeyGroupStreamPartitioner<T,K>	Partitioner selects the target channel based on the key group index.
KeyMap<K,V>	A special Hash Map implementation that can be traversed efficiently in sync with other hash maps.
KeyMap.Entry<K,V>	An entry in the hash table.
KeyMap.LazyFactory<V>	A factory for lazy/on-demand instantiation of values.
KeyMap.TraversalEvaluator<K,V>	A visitor for a traversal over the union of multiple hash maps.
KeySelectorUtil	Utility class that contains helper methods to manipulating KeySelector for streaming.
KeySelectorUtil.ArrayKeySelector<IN>	A key selector for selecting individual array fields as keys and returns them as a Tuple.
KeySelectorUtil.ComparableKeySelector<IN>	A key selector for selecting key fields via a TypeComparator.
KeySelectorUtil.OneKeySelector<IN,K>	Key extractor that extracts a single field via a generic comparator.
LatencyMarker	Special record type carrying a timestamp of its creation time at a source operator and the vertexId and subtask index of the operator.
LatencyStats	The LatencyStats objects are used to track and report on the behavior of latencies across measurements.
LatencyStats.Granularity	Granularity for latency metrics.
LegacyKeyedCoProcessOperator<K,IN1,IN2,OUT>	Deprecated. Replaced by KeyedCoProcessOperator which takes KeyedCoProcessFunction
LegacyKeyedProcessOperator<K,IN,OUT>	Deprecated. Replaced by KeyedProcessOperator which takes KeyedProcessFunction
LegacySinkTransformation<T>	This Transformation represents a stream Sink.
LegacySinkTransformationTranslator<IN>	A TransformationTranslator for the LegacySinkTransformation.
LegacySourceTransformation<T>	This represents a Source.
LegacySourceTransformationTranslator<OUT>	A TransformationTranslator for the LegacySourceTransformation.
ListCheckpointed<T extends Serializable>	Deprecated. If you need to do non-keyed state snapshots of your operator, use CheckpointedFunction.
LocalStreamEnvironment	The LocalStreamEnvironment is a StreamExecutionEnvironment that runs the program locally, multi-threaded, in the JVM where the environment is instantiated.
Mail	An executable bound to a specific operator in the chain, such that it can be picked for downstream mailbox.
MailboxDefaultAction	Interface for the default action that is repeatedly invoked in the mailbox-loop.
MailboxDefaultAction.Controller	This controller is a feedback interface for the default action to interact with the mailbox execution.
MailboxDefaultAction.Suspension	Represents the suspended state of a MailboxDefaultAction, ready to resume.
MailboxExecutorFactory	A factory for creating mailbox executors with a given priority.
MailboxExecutorImpl	Implementation of an executor service build around a mailbox-based execution model.
MailboxMetricsController	Mailbox metrics controller class.
MailboxProcessor	This class encapsulates the logic of the mailbox-based execution model.
MailboxProcessor.MailboxController	Implementation of MailboxDefaultAction.Controller that is connected to a MailboxProcessor instance.
MergingWindowAssigner<T,W extends Window>	A WindowAssigner that can merge windows.
MergingWindowAssigner.MergeCallback<W>	Callback to be used in MergingWindowAssigner.mergeWindows(Collection, MergeCallback) for specifying which windows should be merged.
MergingWindowSet<W extends Window>	Utility for keeping track of merging Windows when using a MergingWindowAssigner in a WindowOperator.
MergingWindowSet.MergeFunction<W>	Callback for MergingWindowSet.addWindow(Window, MergeFunction).
MessageAcknowledgingSourceBase<Type,UId>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
MinWatermarkGauge	A Gauge for exposing the minimum watermark of chosen WatermarkGauges.
MultiInputSortingDataInput<IN,K>	An input that wraps an underlying input and sorts the incoming records.
MultiInputSortingDataInput.SelectableSortingInputs	A wrapper that combines sorting inputs with a InputSelectable that should be used to choose which input to consume next from.
MultiInputTransformationTranslator<OUT>	A TransformationTranslator for the MultipleInputTransformation and the KeyedMultipleInputTransformation.
MultipleConnectedStreams	This is a very basic and rough stub for a class connecting multiple input DataStreams into one, using MultipleInputStreamOperator.
MultipleFuturesAvailabilityHelper	This class is semi-thread safe.
MultipleIdsMessageAcknowledgingSourceBase<Type,UId,SessionId>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
MultipleInputSelectionHandler	This handler is mainly used for selecting the next available input index in StreamMultipleInputProcessor.
MultipleInputStreamOperator<OUT>	Interface for stream operators with multiple Inputs.
MultipleInputStreamTask<OUT>	A StreamTask for executing a MultipleInputStreamOperator and supporting the MultipleInputStreamOperator to select input for reading.
MultipleInputTransformation<OUT>	AbstractMultipleInputTransformation implementation for non-keyed streams.
NonChainedOutput	Used by operator chain and represents a non-chained output of the corresponding stream operator.
NoOpTimestampsAndWatermarks<T>	An implementation of TimestampsAndWatermarks where all watermarking/event-time operations are no-ops.
OneInputStreamOperator<IN,OUT>	Interface for stream operators with one input.
OneInputStreamOperatorFactory<IN,OUT>	A factory to create OneInputStreamOperator.
OneInputStreamTask<IN,OUT>	A StreamTask for executing a OneInputStreamOperator.
OneInputTransformation<IN,OUT>	This Transformation represents the application of a OneInputStreamOperator to one input Transformation.
OneInputTransformationTranslator<IN,OUT>	A TransformationTranslator for the OneInputTransformation.
OnWatermarkCallback<KEY>	A callback registered with the InternalWatermarkCallbackService service.
OperatorChain<OUT,OP extends StreamOperator<OUT>>	The OperatorChain contains all operators that are executed as one chain within a single StreamTask.
OperatorChain.ChainedSource	Wrapper class to access the chained sources and their's outputs.
OperatorEventDispatcherImpl	An implementation of the OperatorEventDispatcher.
OperatorSnapshotFinalizer	This class finalizes OperatorSnapshotFutures.
OperatorSnapshotFutures	Result of StreamOperator.snapshotState(long, long, org.apache.flink.runtime.checkpoint.CheckpointOptions, org.apache.flink.runtime.state.CheckpointStreamFactory).
OrderedStreamElementQueue<OUT>	Ordered StreamElementQueue implementation.
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.
OutputFormatSinkFunction<IN>	Deprecated. Please use the StreamingFileSink for writing to files from a streaming program.
OutputWithChainingCheck<OUT>	This is a wrapper for outputs to check whether the collected record has been emitted to a downstream subtask or to a chained operator.
ParallelSourceFunction<OUT>	Deprecated. This interface is based on the SourceFunction API, which is due to be removed.
PartitionTransformation<T>	This transformation represents a change of partitioning of the input elements.
PartitionTransformationTranslator<OUT>	A TransformationTranslator for the PartitionTransformation.
PassThroughAllWindowFunction<W extends Window,T>	A AllWindowFunction that just emits each input element.
PassThroughWindowFunction<K,W extends Window,T>	A WindowFunction that just emits each input element.
PausableRelativeClock	A RelativeClock whose time progress with respect to the wall clock can be paused and un-paused.
PeriodTimer	Interface for the measurement of the period of time.
PhysicalTransformation<T>	A Transformation that creates a physical operation.
PrintSink<IN>	Sink implementation writing every element to the standard output or standard error stream.
PrintSinkFunction<IN>	Implementation of the SinkFunction writing every tuple to the standard output or standard error stream.
ProcessAllWindowFunction<IN,OUT,W extends Window>	Base abstract class for functions that are evaluated over non-keyed windows using a context for retrieving extra information.
ProcessFunction<I,O>	A function that processes elements of a stream.
ProcessingTimeoutTrigger<T,W extends Window>	A Trigger that can turn any Trigger into a timeout Trigger.
ProcessingTimeService	Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.
ProcessingTimeServiceFactory	A factory for creating processing time services with a given MailboxExecutor.
ProcessingTimeServiceUtil	Utility for classes that implements the ProcessingTimeService interface.
ProcessingTimeSessionWindows	A WindowAssigner that windows elements into sessions based on the current processing time.
ProcessingTimeTrigger	A Trigger that fires once the current system time passes the end of the window to which a pane belongs.
ProcessJoinFunction<IN1,IN2,OUT>	A function that processes two joined elements and produces a single output one.
ProcessOperator<IN,OUT>	A StreamOperator for executing ProcessFunctions.
ProcessWindowFunction<IN,OUT,KEY,W extends Window>	Base abstract class for functions that are evaluated over keyed (grouped) windows using a context for retrieving extra information.
ProgressiveTimestampsAndWatermarks<T>	An implementation of TimestampsAndWatermarks that does periodic watermark emission and keeps track of watermarks on a per-split basis.
PurgingTrigger<T,W extends Window>	A trigger that can turn any Trigger into a purging Trigger.
PushingAsyncDataInput<T>	The variant of PullingAsyncDataInput that is defined for handling both network input and source input in a unified way via PushingAsyncDataInput.emitNext(DataOutput) instead of returning Optional.empty() via PullingAsyncDataInput.pollNext().
PushingAsyncDataInput.DataOutput<T>	Basic data output interface used in emitting the next element from data input.
QueryableAppendingStateOperator<IN>	Internal operator handling queryable AppendingState instances.
QueryableStateStream<K,V>	Deprecated. The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
QueryableValueStateOperator<IN>	Internal operator handling queryable ValueState instances.
RandomGenerator<T>	Random generator.
RebalancePartitioner<T>	Partitioner that distributes the data equally by cycling through the output channels.
RecordAttributes	A RecordAttributes describes the attributes of records from the current RecordAttributes until the next one is received.
RecordAttributesBuilder	The builder class for RecordAttributes.
RecordAttributesCombiner	RecordAttributesValve combine RecordAttributes from different input channels.
RecordProcessorUtils	Utility class for creating record processor for Input StreamOperator.
RecordWriterOutput<OUT>	Implementation of Output that sends data using a RecordWriter.
RecoverableStreamTaskInput<T>	A StreamTaskInput used during recovery of in-flight data.
ReduceApplyAllWindowFunction<W extends Window,T,R>	Internal AllWindowFunction that is used for implementing a fold on a window configuration that only allows AllWindowFunction and cannot directly execute a ReduceFunction.
ReduceApplyProcessAllWindowFunction<W extends Window,T,R>	Internal ProcessAllWindowFunction that is used for implementing a fold on a window configuration that only allows AllWindowFunction and cannot directly execute a ReduceFunction.
ReduceApplyProcessWindowFunction<K,W extends Window,T,R>	Internal ProcessWindowFunction that is used for implementing a fold on a window configuration that only allows AllWindowFunction and cannot directly execute a ReduceFunction.
ReduceApplyWindowFunction<K,W extends Window,T,R>	Internal WindowFunction that is used for implementing a fold on a window configuration that only allows WindowFunction and cannot directly execute a ReduceFunction.
ReduceTransformation<IN,K>	A Transformation that describes a reduce operation on a KeyedStream.
ReduceTransformationTranslator<IN,KEY>	A TransformationTranslator for the ReduceTransformation.
RegularOperatorChain<OUT,OP extends StreamOperator<OUT>>	A regular non finished on restore OperatorChain.
RemoteStreamEnvironment	A StreamExecutionEnvironment for executing on a cluster.
RescalePartitioner<T>	Partitioner that distributes the data equally by cycling through the output channels.
RescalingStreamTaskNetworkInput<T>	A StreamTaskNetworkInput implementation that demultiplexes virtual channels.
ResultFuture<OUT>	ResultFuture collects data / error in user codes while processing async i/o.
RetryPredicates	Utility class to create concrete retry predicates.
RichAllWindowFunction<IN,OUT,W extends Window>	A RichFunction version of AllWindowFunction.
RichAsyncFunction<IN,OUT>	Rich variant of the AsyncFunction.
RichCoFlatMapFunction<IN1,IN2,OUT>	A RichCoFlatMapFunction represents a FlatMap transformation with two different input types.
RichCoMapFunction<IN1,IN2,OUT>	A RichCoMapFunction represents a Map transformation with two different input types.
RichParallelSourceFunction<OUT>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
RichProcessAllWindowFunction<IN,OUT,W extends Window>	Deprecated. use ProcessAllWindowFunction instead
RichProcessWindowFunction<IN,OUT,KEY,W extends Window>	Deprecated. use ProcessWindowFunction instead
RichSinkFunction<IN>	A RichFunction version of SinkFunction.
RichSourceFunction<OUT>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
RichWindowFunction<IN,OUT,KEY,W extends Window>	Rich variant of the WindowFunction.
ScalaProductFieldAccessorFactory	Interface to interact with optional Scala field accessors.
SequenceGenerator<T>	A stateful, re-scalable DataGenerator that emits each number from a given interval exactly once, possibly in parallel.
SerializationSchema<T>	Deprecated. Use SerializationSchema instead.
SessionWindowTimeGapExtractor<T>	A SessionWindowTimeGapExtractor extracts session time gaps for Dynamic Session Window Assigners.
SetupableStreamOperator<OUT>	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.
ShufflePartitioner<T>	Partitioner that distributes the data equally by selecting one output channel randomly.
SideOutputDataStream<T>	A SideOutputDataStream represents a DataStream that contains elements that are emitted from upstream into a side output with some tag.
SideOutputTransformation<T>	This transformation represents a selection of a side output of an upstream operation with a given OutputTag.
SideOutputTransformationTranslator<OUT>	A TransformationTranslator for the SideOutputTransformation.
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.
SimpleStringSchema	Deprecated. Use SimpleStringSchema instead.
SimpleTimerService	Implementation of TimerService that uses a InternalTimerService.
SimpleTransformationTranslator<OUT,T extends org.apache.flink.api.dag.Transformation<OUT>>	A base class for all TransformationTranslators who translate Transformations that have a single operator in their runtime implementation.
SimpleUdfStreamOperatorFactory<OUT>	Udf stream operator factory which just wrap existed AbstractUdfStreamOperator.
SimpleVersionedListState<T>	A ListState that uses a SimpleVersionedSerializer instead of a TypeSerializer.
SingleCheckpointBarrierHandler	SingleCheckpointBarrierHandler is used for triggering checkpoint while reading the first barrier and keeping track of the number of received barriers and consumed barriers.
SingleOutputStreamOperator<T>	SingleOutputStreamOperator represents a user defined transformation applied on a DataStream with one predefined output type.
SinkContextUtil	Utility for creating Sink Contexts.
SinkFunction<IN>	Interface for implementing user defined sink functionality.
SinkFunction.Context	Context that SinkFunctions can use for getting additional data about an input record.
SinkTransformation<InputT,OutputT>	A Transformation for Sink.
SinkTransformationTranslator<Input,Output>	A TransformationTranslator for the SinkTransformation.
SinkV1Adapter<InputT,CommT,WriterStateT,GlobalCommT>	Translates Sink V1 into Sink V2.
SinkV1CommittableDeserializer	This class offers the possibility to deserialize committables that have been written with older Flink releases (i.e. 1.13, 1.14).
SinkWriterOperatorFactory<InputT,CommT>	A StreamOperatorFactory for SinkWriterOperator.
SlidingEventTimeWindows	A WindowAssigner that windows elements into sliding windows based on the timestamp of the elements.
SlidingProcessingTimeWindows	A WindowAssigner that windows elements into sliding windows based on the current system time of the machine the operation is running on.
SocketClientSink<IN>	Socket client that acts as a streaming sink.
SocketStreamIterator<T>	An iterator that returns the data from a socket stream.
SocketTextStreamFunction	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
SortingDataInput<T,K>	A StreamTaskInput which sorts in the incoming records from a chained input.
SourceFunction<T>	Deprecated. This interface will be removed in future versions.
SourceFunction.SourceContext<T>	Interface that source functions use to emit elements, and possibly watermarks.
SourceOperator<OUT,SplitT extends org.apache.flink.api.connector.source.SourceSplit>	Base source operator only used for integrating the source reader which is proposed by FLIP-27.
SourceOperatorFactory<OUT>	The Factory class for SourceOperator.
SourceOperatorStreamTask<T>	A subclass of StreamTask for executing the SourceOperator.
SourceOperatorStreamTask.AsyncDataOutputToOutput<T>	Implementation of PushingAsyncDataInput.DataOutput that wraps a specific Output.
SourceOutputWithWatermarks<T>	Implementation of the SourceOutput.
SourceStreamTask<OUT,SRC extends SourceFunction<OUT>,OP extends StreamSource<OUT,SRC>>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
SourceTransformation<OUT,SplitT extends org.apache.flink.api.connector.source.SourceSplit,EnumChkT>	A PhysicalTransformation for Source.
SourceTransformationTranslator<OUT,SplitT extends org.apache.flink.api.connector.source.SourceSplit,EnumChkT>	A TransformationTranslator for the SourceTransformation.
SourceTransformationWrapper<T>	This Transformation is a phantom transformation which is used to expose a default parallelism to downstream.
StandardSinkTopologies	This utility class provides building blocks for custom topologies.
StatefulSequenceSource	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
StatusWatermarkValve	A StatusWatermarkValve embodies the logic of how Watermark and WatermarkStatus are propagated to downstream outputs, given a set of one or multiple subpartitions that continuously receive them.
StatusWatermarkValve.SubpartitionStatus	An SubpartitionStatus keeps track of a subpartition's last watermark, stream status, and whether or not the subpartition's current watermark is aligned with the overall watermark output from the valve.
StreamConfig	Internal configuration for a StreamOperator.
StreamConfig.InputConfig	Interface representing chained inputs.
StreamConfig.InputRequirement	Requirements of the different inputs of an operator.
StreamConfig.NetworkInputConfig	A representation of a Network StreamConfig.InputConfig.
StreamConfig.SourceInputConfig	A serialized representation of an input.
StreamEdge	An edge in the streaming topology.
StreamElement	An element in a data stream.
StreamElementQueue<OUT>	Interface for stream element queues for the AsyncWaitOperator.
StreamElementSerializer<T>	Serializer for StreamRecord, Watermark, LatencyMarker, and WatermarkStatus.
StreamElementSerializer.StreamElementSerializerSnapshot<T>	Configuration snapshot specific to the StreamElementSerializer.
StreamExchangeMode	The data exchange mode between operators during StreamGraph generation.
StreamExecutionEnvironment	The StreamExecutionEnvironment is the context in which a streaming program is executed.
StreamExecutionEnvironmentFactory	Factory class for stream execution environments.
StreamFilter<IN>	A StreamOperator for executing FilterFunctions.
StreamFlatMap<IN,OUT>	A StreamOperator for executing FlatMapFunctions.
StreamGraph	Class representing the streaming topology.
StreamGraphGenerator	A generator that generates a StreamGraph from a graph of Transformations.
StreamGraphHasher	Interface for different implementations of generating hashes over a stream graph.
StreamGraphHasherV2	StreamGraphHasher from Flink 1.2.
StreamGraphUserHashHasher	StreamGraphHasher that works with user provided hashes.
StreamGraphUtils	Utility class that contains helper methods to generating StreamGraph.
StreamGroupedReduceOperator<IN>	A StreamOperator for executing a ReduceFunction on a KeyedStream.
StreamingFileSink<IN>	Deprecated. Use org.apache.flink.connector.file.sink.FileSink instead.
StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BucketsBuilder<IN,BucketID,T>>	The base abstract class for the StreamingFileSink.RowFormatBuilder and StreamingFileSink.BulkFormatBuilder.
StreamingFileSink.BulkFormatBuilder<IN,BucketID,T extends StreamingFileSink.BulkFormatBuilder<IN,BucketID,T>>	A builder for configuring the sink for bulk-encoding formats, e.g.
StreamingFileSink.DefaultBulkFormatBuilder<IN>	Builder for the vanilla StreamingFileSink using a bulk format.
StreamingFileSink.DefaultRowFormatBuilder<IN>	Builder for the vanilla StreamingFileSink using a row format.
StreamingFileSink.RowFormatBuilder<IN,BucketID,T extends StreamingFileSink.RowFormatBuilder<IN,BucketID,T>>	A builder for configuring the sink for row-wise encoding formats.
StreamingFileSinkHelper<IN>	Helper for StreamingFileSink.
StreamingFunctionUtils	Utility class that contains helper methods to work with Flink Streaming Functions.
StreamingJobGraphGenerator	The StreamingJobGraphGenerator converts a StreamGraph into a JobGraph.
StreamingRuntimeContext	Implementation of the RuntimeContext, for streaming operators.
StreamInputProcessor	Interface for processing records by StreamTask.
StreamIterationHead<OUT>	A special StreamTask that is used for executing feedback edges.
StreamIterationTail<IN>	A special StreamTask that is used for executing feedback edges.
StreamMap<IN,OUT>	A StreamOperator for executing MapFunctions.
StreamMultipleInputProcessor	Input processor for MultipleInputStreamOperator.
StreamMultipleInputProcessorFactory	A factory for StreamMultipleInputProcessor.
StreamNode	Class representing the operators in the streaming programs, with all their properties.
StreamOneInputProcessor<IN>	Input reader for OneInputStreamTask.
StreamOperator<OUT>	Basic interface for stream operators.
StreamOperatorFactory<OUT>	A factory to create StreamOperator.
StreamOperatorFactoryUtil	A utility to instantiate new operators with a given factory.
StreamOperatorParameters<OUT>	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. backends, raw state, and timer service manager.
StreamOperatorStateHandler	Class encapsulating various state backend handling logic for StreamOperator implementations.
StreamOperatorStateHandler.CheckpointedStreamOperator	Custom state handling hooks to be invoked by StreamOperatorStateHandler.
StreamOperatorWrapper<OUT,OP extends StreamOperator<OUT>>	This class handles the finish, endInput and other related logic of a StreamOperator.
StreamPartitioner<T>	A special ChannelSelector for use in streaming programs.
StreamPipelineOptions	The configuration options for job execution.
StreamProject<IN,OUT extends org.apache.flink.api.java.tuple.Tuple>	A StreamOperator for executing projections on streams.
StreamProjection<IN>	The result of DataStream.project(int...).
StreamRecord<T>	One value in a data stream.
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.
StreamTask<OUT,OP extends StreamOperator<OUT>>	Base class for all streaming tasks.
StreamTask.CanEmitBatchOfRecordsChecker	Check whether records can be emitted in batch.
StreamTaskActionExecutor	Executes Runnable, ThrowingRunnable, or Callable.
StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor	Deprecated. this class should only be used in SourceStreamTask which exposes the checkpoint lock as part of Public API.
StreamTaskCancellationContext	Context on the StreamTask for figuring out whether it has been cancelled.
StreamTaskException	An exception that is thrown by the stream vertices when encountering an illegal condition.
StreamTaskExternallyInducedSourceInput<T>	A subclass of StreamTaskSourceInput for ExternallyInducedSourceReader.
StreamTaskFinishedOnRestoreSourceInput<T>	A special source input implementation that immediately emit END_OF_INPUT.
StreamTaskInput<T>	Basic interface for inputs of stream operators.
StreamTaskNetworkInput<T>	Implementation of StreamTaskInput that wraps an input from network taken from CheckpointedInputGate.
StreamTaskNetworkInputFactory	Factory for StreamTaskNetworkInput and RescalingStreamTaskNetworkInput.
StreamTaskSourceInput<T>	Implementation of StreamTaskInput that reads data from the SourceOperator and returns the DataInputStatus to indicate whether the source state is available, unavailable or finished.
StreamTaskStateInitializer	This is the interface through which stream task expose a StreamOperatorStateContext to their operators.
StreamTaskStateInitializerImpl	This class is the main implementation of a StreamTaskStateInitializer.
StreamTwoInputProcessorFactory	A factory to create StreamMultipleInputProcessor for two input case.
SubtaskCheckpointCoordinator	Coordinates checkpointing-related work for a subtask (i.e.
SumAggregator<T>	An AggregationFunction that sums up fields.
SumFunction	Internal function for summing up contents of fields.
SupportsPostCommitTopology<CommittableT>	Allows expert users to implement a custom topology after Committer.
SupportsPreCommitTopology<WriterResultT,CommittableT>	Allows expert users to implement a custom topology after SinkWriter and before Committer.
SupportsPreWriteTopology<InputT>	Allows expert users to implement a custom topology before SinkWriter.
SystemProcessingTimeService	A TimerService which assigns as current processing time the result of calling System.currentTimeMillis() and registers timers using a ScheduledThreadPoolExecutor.
TaskMailbox	A task mailbox provides read and write access to a mailbox and has a lifecycle of open -> (quiesced) -> closed.
TaskMailbox.MailboxClosedException	Exception thrown when TaskMailbox is closed.
TaskMailbox.State	This enum represents the states of the mailbox lifecycle.
TaskMailboxImpl	Implementation of TaskMailbox in a BlockingQueue fashion and tailored towards our use case with multiple writers and single reader.
TestProcessingTimeService	This is a TimerService and ProcessingTimeService used strictly for testing the processing time functionality.
Time	Deprecated. Use Duration
TimeCharacteristic	Deprecated. In Flink 1.12 the default stream time characteristic has been changed to TimeCharacteristic.EventTime, thus you don't need to call this method for enabling event-time support anymore.
TimeDomain	TimeDomain specifies whether a firing timer is based on event time or processing time.
TimeEvictor<W extends Window>	An Evictor that keeps elements for a certain amount of time.
TimerException	RuntimeException for wrapping exceptions that are thrown in the timer callback of the timer service in StreamTask.
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.
TimerService	Interface for working with time and timers.
TimerService	A common timer service interface with life cycle methods.
TimestampAssigner<T>	Deprecated. use TimestampAssigner
TimestampedCollector<T>	Wrapper around an Output for user functions that expect a Output.
TimestampedFileInputSplit	A FileInputSplit with TimestampedInputSplit.
TimestampedInputSplit	An extended InputSplit that also includes information about: The modification time of the file this split belongs to.
TimestampedValue<T>	Stores the value and the timestamp of the record.
TimestampsAndWatermarks<T>	Basic interface for the timestamp extraction and watermark generation logic for the SourceReader.
TimestampsAndWatermarks.TimestampsAndWatermarksContextProvider	Helper class to construct TimestampsAndWatermarksContext.
TimestampsAndWatermarks.WatermarkUpdateListener	Lets the owner/creator of the output know about latest emitted watermark.
TimestampsAndWatermarksContext	A simple implementation of a context that is both TimestampAssignerSupplier.Context and WatermarkGeneratorSupplier.Context.
TimestampsAndWatermarksOperator<T>	A stream operator that may do one or both of the following: extract timestamps from events and generate watermarks.
TimestampsAndWatermarksOperator.WatermarkEmitter	Implementation of the WatermarkEmitter, based on the components that are available inside a stream operator.
TimestampsAndWatermarksTransformation<IN>	A PhysicalTransformation for a DataStream.assignTimestampsAndWatermarks(WatermarkStrategy).
TimestampsAndWatermarksTransformationTranslator<IN>	A TransformationTranslator for the TimestampsAndWatermarksTransformation.
TimeWindow	A Window that represents a time interval from start (inclusive) to end (exclusive).
TimeWindow.Serializer	The serializer used to write the TimeWindow type.
TimeWindow.Serializer.TimeWindowSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
TransformationTranslator<OUT,T extends org.apache.flink.api.dag.Transformation<OUT>>	A TransformationTranslator is responsible for translating a given Transformation to its runtime implementation depending on the execution mode.
TransformationTranslator.Context	A context giving the necessary information for the translation of a given transformation.
Trigger<T,W extends Window>	A Trigger determines when a pane of a window should be evaluated to emit the results for that part of the window.
Trigger.OnMergeContext	Extension of Trigger.TriggerContext that is given to Trigger.onMerge(Window, OnMergeContext).
Trigger.TriggerContext	A context object that is given to Trigger methods to allow them to register timer callbacks and deal with state.
Triggerable<K,N>	Interface for things that can be called by InternalTimerService.
TriggerResult	Result type for trigger methods.
TumblingEventTimeWindows	A WindowAssigner that windows elements into windows based on the timestamp of the elements.
TumblingProcessingTimeWindows	A WindowAssigner that windows elements into windows based on the current system time of the machine the operation is running on.
TwoInputStreamOperator<IN1,IN2,OUT>	Interface for stream operators with two inputs.
TwoInputStreamOperatorFactory<IN1,IN2,OUT>	A factory to create TwoInputStreamOperator.
TwoInputStreamTask<IN1,IN2,OUT>	A StreamTask for executing a TwoInputStreamOperator and supporting the TwoInputStreamOperator to select input for reading.
TwoInputTransformation<IN1,IN2,OUT>	This Transformation represents the application of a TwoInputStreamOperator to two input Transformations.
TwoInputTransformationTranslator<IN1,IN2,OUT>	A TransformationTranslator for the TwoInputTransformation.
TwoPhaseCommitSinkFunction<IN,TXN,CONTEXT>	This is a recommended base class for all of the SinkFunction that intend to implement exactly-once semantic.
TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>	State POJO class coupling pendingTransaction, context and pendingCommitTransactions.
TwoPhaseCommitSinkFunction.StateSerializer<TXN,CONTEXT>	Custom TypeSerializer for the sink state.
TwoPhaseCommitSinkFunction.StateSerializerSnapshot<TXN,CONTEXT>	Snapshot for the TwoPhaseCommitSinkFunction.StateSerializer.
TwoPhaseCommitSinkFunction.TransactionHolder<TXN>	Adds metadata (currently only the start time of the transaction) to the transaction object.
TypeInformationSerializationSchema<T>	Deprecated. Use TypeInformationSerializationSchema instead.
UdfStreamOperatorFactory<OUT>	Udf stream operator factory.
UncheckpointedCollectResultBuffer<T>	A buffer which encapsulates the logic of dealing with the response from the CollectSinkFunction.
UnionTransformation<T>	This transformation represents a union of several input Transformations.
UnionTransformationTranslator<OUT>	A TransformationTranslator for the UnionTransformation.
UnorderedStreamElementQueue<OUT>	Unordered implementation of the StreamElementQueue.
UnsupportedTimeCharacteristicException	An exception that indicates that a time characteristic was used that is not supported in the current operation.
UpstreamRecoveryTracker	Tracks status of upstream channels while they recover.
UserFunctionProvider<F extends org.apache.flink.api.common.functions.Function>	The interface with user function.
Watermark	A Watermark tells operators that no elements with a timestamp older or equal to the watermark timestamp should arrive at the operator.
WatermarkGauge	A Gauge for exposing the current input/output watermark.
WatermarkGaugeExposingOutput<T>	An Output that measures the last emitted watermark with a WatermarkGauge.
WatermarkStatus	A Watermark Status element informs stream tasks whether or not they should continue to expect watermarks from the input stream that sent them.
WatermarkToDataOutput	An adapter that exposes a WatermarkOutput based on a PushingAsyncDataInput.DataOutput.
Window	A Window is a grouping of elements into finite buckets.
WindowAssigner<T,W extends Window>	A WindowAssigner assigns zero or more Windows to an element.
WindowAssigner.WindowAssignerContext	A context provided to the WindowAssigner that allows it to query the current processing time.
WindowedStream<T,K,W extends Window>	A WindowedStream represents a data stream where elements are grouped by key, and for each key, the stream of elements is split into windows based on a WindowAssigner.
WindowFunction<IN,OUT,KEY,W extends Window>	Base interface for functions that are evaluated over keyed (grouped) windows.
WindowOperator<K,IN,ACC,OUT,W extends Window>	An operator that implements the logic for windowing based on a WindowAssigner and Trigger.
WindowOperator.Timer<K,W extends Window>	Internal class for keeping track of in-flight timers.
WindowOperatorBuilder<T,K,W extends Window>	A builder for creating WindowOperators.
WindowStagger	A WindowStagger staggers offset in runtime for each window assignment.
WithBoundedness	An interface to be implemented by transformations that have explicitly set Boundedness.
WithMasterCheckpointHook<E>	This interface can be implemented by streaming functions that need to trigger a "global action" on the master (in the checkpoint coordinator) as part of every checkpoint and restore operation.
WithPostCommitTopology<InputT,CommT>	Deprecated. Please implement Sink, SupportsCommitter and SupportsPostCommitTopology instead.
WithPreCommitTopology<InputT,CommT>	Deprecated. Please implement Sink, SupportsCommitter and SupportsPreCommitTopology instead.
WithPreWriteTopology<InputT>	Deprecated. Please implement Sink and SupportsPreWriteTopology instead.
WriteFormat<IN>	Deprecated. Please use the StreamingFileSink for writing to files from a streaming program.
WriteFormatAsCsv<IN>	Deprecated. Please use the StreamingFileSink for writing to files from a streaming program.
WriteFormatAsText<IN>	Deprecated. Please use the StreamingFileSink for writing to files from a streaming program.
WriteSinkFunction<IN>	Deprecated. Please use the StreamingFileSink for writing to files from a streaming program.
WriteSinkFunctionByMillis<IN>	Deprecated. Please use the StreamingFileSink for writing to files from a streaming program.
YieldingOperatorFactory<OUT>	An operator that needs access to the MailboxExecutor to yield to downstream operators needs to be created through a factory implementing this interface.