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

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

Package	Description
org.apache.flink.streaming.api.collector.selector
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
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.tasks	This package contains classes that realize streaming tasks.

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

Class and Description
OperatorChain.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.functions.sink.filesystem

Class and Description
ProcessingTimeCallback Interface for processing-time callbacks that can be registered at a ProcessingTimeService.

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

Class and Description
ProcessingTimeCallback Interface for processing-time callbacks that can be registered at a ProcessingTimeService.
ProcessingTimeService Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.
StreamTask Base class for all streaming tasks.

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

Class and Description
StreamTask Base class for all streaming tasks.

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

Class and Description
OperatorChain.WatermarkGaugeExposingOutput An Output that measures the last emitted watermark with a WatermarkGauge.
StreamTask Base class for all streaming tasks.
TwoInputStreamTask A StreamTask for executing a TwoInputStreamOperator.

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

Class and Description
ProcessingTimeCallback Interface for processing-time callbacks that can be registered at a ProcessingTimeService.

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

Class and Description
AsyncExceptionHandler An interface marking a task as capable of handling exceptions thrown by different threads, other than the one executing the task itself.
AsynchronousException An exception for wrapping exceptions that are thrown by an operator in threads other than the main compute thread of that operator.
CheckpointExceptionHandler Handler for exceptions that happen on checkpointing.
CheckpointExceptionHandlerFactory This factory produces CheckpointExceptionHandler instances that handle exceptions during checkpointing in a StreamTask.
OneInputStreamTask A StreamTask for executing a OneInputStreamOperator.
OperatorChain The OperatorChain contains all operators that are executed as one chain within a single StreamTask.
OperatorChain.WatermarkGaugeExposingOutput An Output that measures the last emitted watermark with a WatermarkGauge.
ProcessingTimeCallback Interface for processing-time callbacks that can be registered at a ProcessingTimeService.
ProcessingTimeService Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.
SourceStreamTask StreamTask for executing a StreamSource.
StreamTask Base class for all streaming tasks.