An interface marking a task as capable of handling exceptions thrown by different threads, other than the one executing the task itself.
Handler for exceptions that happen on checkpointing.
Interface for processing-time callbacks that can be registered at a
|OperatorChain<OUT,OP extends StreamOperator<OUT>>||
Defines the current processing time and handles all related actions, such as register timers for tasks to be executed in the future.
|SourceStreamTask<OUT,SRC extends SourceFunction<OUT>,OP extends StreamSource<OUT,SRC>>|
|StoppableSourceStreamTask<OUT,SRC extends SourceFunction<OUT> & StoppableFunction>||
Stoppable task for executing stoppable streaming sources.
|StreamTask<OUT,OP extends StreamOperator<OUT>>||
Base class for all streaming tasks.
This runnable executes the asynchronous parts of all involved backend snapshots for the subtask.
This is a
An exception for wrapping exceptions that are thrown by an operator in threads other than the main compute thread of that operator.
A special exception that signifies that the cause exception came from a chained operator.
An exception that is thrown by the stream vertices when encountering an illegal condition.
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–2019 The Apache Software Foundation. All rights reserved.