Uses of Package
org.apache.flink.streaming.runtime.tasks

Packages that use org.apache.flink.streaming.runtime.tasks

Package	Description
org.apache.flink.cep.operator
org.apache.flink.connector.file.sink.compactor.operator
org.apache.flink.connector.file.table.stream
org.apache.flink.runtime.asyncprocessing.operators
org.apache.flink.state.api.output.operators
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.connector.sink2
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.api.operators.sorted.state
org.apache.flink.streaming.api.operators.sortpartition
org.apache.flink.streaming.api.operators.source
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.io.checkpointing
org.apache.flink.streaming.runtime.io.recovery
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.tasks.mailbox
org.apache.flink.table.runtime.operators
org.apache.flink.table.runtime.operators.dynamicfiltering
org.apache.flink.table.runtime.operators.fusion
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.multipleinput
org.apache.flink.table.runtime.operators.wmassigners

Classes in org.apache.flink.streaming.runtime.tasks used by org.apache.flink.cep.operator

Class	Description
StreamTask	Base class for all streaming tasks.

Classes in org.apache.flink.streaming.runtime.tasks used by org.apache.flink.connector.file.sink.compactor.operator

Class	Description
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.

Classes in org.apache.flink.streaming.runtime.tasks used by org.apache.flink.connector.file.table.stream

Class	Description
ProcessingTimeService	Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.

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

Class	Description
StreamTask	Base class for all streaming tasks.

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

Class	Description
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.
StreamTask	Base class for all streaming tasks.

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

Class	Description
ProcessingTimeService	Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.
TimerService	A common timer service interface with life cycle methods.

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

Class	Description
StreamTask	Base class for all streaming tasks.

Classes in org.apache.flink.streaming.runtime.tasks used by org.apache.flink.streaming.api.functions.sink.filesystem

Class	Description
ProcessingTimeService	Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.

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

Class	Description
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.

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

Class	Description
OperatorChain	The OperatorChain contains all operators that are executed as one chain within a single StreamTask.
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.
StreamTask	Base class for all streaming tasks.
StreamTask.CanEmitBatchOfRecordsChecker	Check whether records can be emitted in batch.
StreamTaskCancellationContext	Context on the StreamTask for figuring out whether it has been cancelled.
WatermarkGaugeExposingOutput	An Output that measures the last emitted watermark with a WatermarkGauge.

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

Class	Description
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.
StreamTask	Base class for all streaming tasks.

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

Class	Description
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.

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

Class	Description
ProcessingTimeService	Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.
StreamTaskCancellationContext	Context on the StreamTask for figuring out whether it has been cancelled.

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

Class	Description
StreamTask	Base class for all streaming tasks.

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

Class	Description
ProcessingTimeService	Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.

Classes in org.apache.flink.streaming.runtime.tasks used by org.apache.flink.streaming.runtime.io

Class	Description
OperatorChain	The OperatorChain contains all operators that are executed as one chain within a single StreamTask.
OutputWithChainingCheck	This is a wrapper for outputs to check whether the collected record has been emitted to a downstream subtask or to a chained operator.
StreamTask.CanEmitBatchOfRecordsChecker	Check whether records can be emitted in batch.
WatermarkGaugeExposingOutput	An Output that measures the last emitted watermark with a WatermarkGauge.

Classes in org.apache.flink.streaming.runtime.tasks used by org.apache.flink.streaming.runtime.io.checkpointing

Class	Description
SubtaskCheckpointCoordinator	Coordinates checkpointing-related work for a subtask (i.e.
TimerService	A common timer service interface with life cycle methods.

Classes in org.apache.flink.streaming.runtime.tasks used by org.apache.flink.streaming.runtime.io.recovery

Class	Description
StreamTask.CanEmitBatchOfRecordsChecker	Check whether records can be emitted in batch.

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

Class	Description
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.

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

Class	Description
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.

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

Class	Description
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.
StreamTask	Base class for all streaming tasks.

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

Class	Description
AbstractTwoInputStreamTask	Abstract class for executing a TwoInputStreamOperator.
ContainingTaskDetails	Details about the operator containing task (such as StreamTask).
FinishedOnRestoreInput	A fake Input for finished on restore tasks.
OneInputStreamTask	A StreamTask for executing a OneInputStreamOperator.
OperatorChain	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.
ProcessingTimeService	Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.
ProcessingTimeServiceFactory	A factory for creating processing time services with a given MailboxExecutor.
StreamOperatorWrapper	This class handles the finish, endInput and other related logic of a StreamOperator.
StreamTask	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.
TimerService	A common timer service interface with life cycle methods.
WatermarkGaugeExposingOutput	An Output that measures the last emitted watermark with a WatermarkGauge.

Classes in org.apache.flink.streaming.runtime.tasks used by org.apache.flink.streaming.runtime.tasks.mailbox

Class	Description
StreamTaskActionExecutor	Executes Runnable, ThrowingRunnable, or Callable.
TimerService	A common timer service interface with life cycle methods.

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

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

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

Class	Description
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.

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

Class	Description
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.
StreamTask	Base class for all streaming tasks.

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

Class	Description
StreamTask	Base class for all streaming tasks.

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

Class	Description
ProcessingTimeServiceAware	Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.

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

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