Package | Description |
---|---|
org.apache.flink.cep.operator | |
org.apache.flink.state.api.runtime | |
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.connectors.fs.bucketing | |
org.apache.flink.streaming.connectors.kafka.internal | |
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.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.wmassigners |
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 . |
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.
|
StreamTask
Base class for all streaming tasks.
|
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 . |
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 . |
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.
|
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.
During transitional period it is used in StreamTask (until StreamTask.getCheckpointLock()
is pushed down to SourceStreamTask ). |
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.
|
StreamTask
Base class for all streaming tasks.
|
Class and Description |
---|
ProcessingTimeCallback
Interface for processing-time callbacks that can be registered at a
ProcessingTimeService . |
StreamTask
Base class for all streaming tasks.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.