See: Description
Class | Description |
---|---|
DefaultTimeServiceProvider |
A
TimeServiceProvider which assigns as current processing time the result of calling
System.currentTimeMillis() and registers timers using a ScheduledThreadPoolExecutor . |
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.
|
TestTimeServiceProvider |
This is a
TimeServiceProvider used strictly for testing the
processing time functionality. |
TimeServiceProvider |
Defines the current processing time and handles all related actions,
such as register timers for tasks to be executed in the future.
|
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.