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.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.
|
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 . |
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.
|
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 . |
StreamTask
Base class for all streaming tasks.
|
TwoInputStreamTask
A
StreamTask that executes a TwoInputStreamOperator but does not support
the TwoInputStreamOperator to select input for reading. |
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.
|
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.
|
StreamTask
Base class for all streaming tasks.
|
StreamTask.ActionContext
The action context is passed as parameter into the default action method and holds control methods for feedback
of from the default action to the mailbox.
|
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 . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.