Class and Description |
---|
StreamTask
Base class for all streaming tasks.
|
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.
|
TimerService
A common timer service interface with life cycle methods.
|
Class and Description |
---|
OperatorChain.WatermarkGaugeExposingOutput
An
Output that measures the last emitted watermark with a WatermarkGauge . |
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.
|
Class and Description |
---|
ProcessingTimeServiceAware
Interface for
StreamOperatorFactory , which
enables stream operators to access ProcessingTimeService . |
Class and 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.
|
Class and 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.
|
Class and Description |
---|
ProcessingTimeServiceAware
Interface for
StreamOperatorFactory , which
enables stream operators to access ProcessingTimeService . |
Class and Description |
---|
ProcessingTimeService
Defines the current processing time and handles all related actions, such as register timers for
tasks to be executed in the future.
|
Class and Description |
---|
ProcessingTimeCallback
Interface for processing-time callbacks that can be registered at a
ProcessingTimeService . |
Class and Description |
---|
ProcessingTimeService
Defines the current processing time and handles all related actions, such as register timers for
tasks to be executed in the future.
|
Class and Description |
---|
ProcessingTimeService
Defines the current processing time and handles all related actions, such as register timers for
tasks to be executed in the future.
|
Class and Description |
---|
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 . |
SubtaskCheckpointCoordinator
Coordinates checkpointing-related work for a subtask (i.e.
|
Class and Description |
---|
ProcessingTimeCallback
Interface for processing-time callbacks that can be registered at a
ProcessingTimeService . |
Class and Description |
---|
AbstractTwoInputStreamTask
Abstract class for executing a
TwoInputStreamOperator . |
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.
|
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.
|
ProcessingTimeServiceFactory
A factory for creating processing time services with a given
MailboxExecutor . |
StreamOperatorWrapper
This class handles the close, endInput and other related logic of a
StreamOperator . |
StreamTask
Base class for all streaming tasks.
|
StreamTaskActionExecutor |
StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor
Deprecated.
this class should only be used in
SourceStreamTask which exposes the
checkpoint lock as part of Public API. |
TimerService
A common timer service interface with life cycle methods.
|
Class and Description |
---|
StreamTaskActionExecutor |
Class and Description |
---|
ProcessingTimeService
Defines the current processing time and handles all related actions, such as register timers for
tasks to be executed in the future.
|
Class and 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 . |
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.
|
ProcessingTimeServiceAware
Interface for
StreamOperatorFactory , which
enables stream operators to access ProcessingTimeService . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.