Package | Description |
---|---|
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.operators |
This package contains the operators that perform the stream transformations.
|
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Class and Description |
---|
OperatorStateHandles
This class holds all state handles for one operator.
|
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 |
---|
ProcessingTimeCallback
Interface for processing-time callbacks that can be registered at a
ProcessingTimeService . |
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.
|
OneInputStreamTask
A
StreamTask for executing a OneInputStreamOperator . |
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.
|
SourceStreamTask
StreamTask for executing a StreamSource . |
StreamTask
Base class for all streaming tasks.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.