| CheckpointingMode |
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
| CheckpointType |
Describes the type in which a checkpoint should be taken.
|
| JobClient |
A client that is scoped to a specific job.
|
| JobExecutionStatusEvent |
Job execution status event.
|
| JobStatusChangedEvent |
Basic job status event.
|
| JobStatusChangedListener |
When job is created or its status is changed, Flink will generate job event and notify job status
changed listener.
|
| JobStatusChangedListenerFactory.Context |
|
| PipelineExecutor |
The entity responsible for executing a Pipeline, i.e. a user job. |
| PipelineExecutorFactory |
|
| PipelineExecutorServiceLoader |
An interface to be implemented by the entity responsible for finding the correct PipelineExecutor to execute a given Pipeline. |
| RecoveryClaimMode |
Defines state files ownership when Flink restore from a given savepoint or retained checkpoint.
|
| SavepointFormatType |
Describes the binary format in which a savepoint should be taken.
|