| Class | Description |
|---|---|
| CheckpointCoordinator |
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
|
| CheckpointCoordinatorDeActivator |
This actor listens to changes in the JobStatus and activates or deactivates the periodic
checkpoint scheduler.
|
| PendingCheckpoint |
A pending checkpoint is a checkpoint that has been started, but has not been
acknowledged by all tasks that need to acknowledge it.
|
| StateForTask |
Simple bean to describe the state belonging to a parallel operator.
|
| SuccessfulCheckpoint |
A successful checkpoint describes a checkpoint after all required tasks acknowledged it (with their state)
and that is considered completed.
|
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.