Package | Description |
---|---|
org.apache.flink.streaming.api.collector.selector | |
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.
|
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.
|
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.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 . |
Class and Description |
---|
ProcessingTimeCallback
Interface for processing-time callbacks that can be registered at a
ProcessingTimeService . |
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.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.