See: Description
Class | Description |
---|---|
OneInputStreamTask<IN,OUT> | |
OperatorChain<OUT> |
The
OperatorChain contains all operators that are executed as one chain within a single
StreamTask . |
SourceStreamTask<OUT,SRC extends SourceFunction<OUT>,OP extends StreamSource<OUT,SRC>> |
Task for executing streaming sources.
|
StoppableSourceStreamTask<OUT,SRC extends SourceFunction<OUT> & StoppableFunction> |
Stoppable task for executing stoppable streaming sources.
|
StreamIterationHead<OUT> | |
StreamIterationTail<IN> | |
StreamTask<OUT,Operator extends StreamOperator<OUT>> |
Base class for all streaming tasks.
|
StreamTaskState |
The state checkpointed by a
AbstractStreamOperator . |
StreamTaskStateList |
List of task states for a chain of streaming tasks.
|
TwoInputStreamTask<IN1,IN2,OUT> |
Exception | Description |
---|---|
AsynchronousException |
RuntimeException for wrapping exceptions that are thrown in Threads that are not the
main compute Thread. |
ExceptionInChainedOperatorException |
A special exception that signifies that the cause exception came from a chained operator.
|
StreamTaskException |
An exception that is thrown by the stream vertices when encountering an
illegal condition.
|
TimerException |
RuntimeException for wrapping exceptions that are thrown in the timer callback of
the timer service in StreamTask . |
The tasks merely set up the distributed stream coordination and the checkpointing. Internally, the tasks create one or more operators, perform the stream transformations.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.