| Interface | Description |
|---|---|
| CheckpointableTask |
A task that participates in checkpointing.
|
| CoordinatedTask |
An task that is coordinated, i.e. contains operators coordinated by
OperatorCoordinator. |
| InputSplitProvider |
An input split provider can be successively queried to provide a series of
InputSplit
objects a task is supposed to consume in the course of its execution. |
| TaskInvokable |
An invokable part of the task.
|
| TaskOperatorEventGateway |
Gateway to send an
OperatorEvent or CoordinationRequest from a Task to the OperatorCoordinator JobManager side. |
| Class | Description |
|---|---|
| AbstractInvokable |
A base implementation of
TaskInvokable, CheckpointableTask, and CoordinatedTask with most methods throwing UnsupportedOperationException or doing
nothing. |
| CheckpointCoordinatorConfiguration |
Configuration settings for the
CheckpointCoordinator. |
| CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
CheckpointCoordinatorConfiguration builder. |
| JobCheckpointingSettings |
The JobCheckpointingSettings are attached to a JobGraph and describe the settings for the
asynchronous checkpoints of the JobGraph, such as interval.
|
| Exception | Description |
|---|---|
| InputSplitProviderException |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.