Modifier and Type | Field and Description |
---|---|
static CheckpointType |
CheckpointType.DEFAULT |
Modifier and Type | Method and Description |
---|---|
static CheckpointType |
CheckpointType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static CheckpointType[] |
CheckpointType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CompletedCheckpoint> |
CheckpointCoordinator.triggerCheckpoint(CheckpointType checkpointType)
Triggers one new checkpoint with the given checkpointType.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Long> |
TriggerCheckpointFunction.apply(JobID jobId,
CheckpointType checkpointType,
Time timeout) |
CompletableFuture<Acknowledge> |
DispatcherCachedOperationsHandler.triggerCheckpoint(AsynchronousJobOperationKey operationKey,
CheckpointType checkpointType,
Time timeout) |
CompletableFuture<Acknowledge> |
Dispatcher.triggerCheckpoint(AsynchronousJobOperationKey operationKey,
CheckpointType checkpointType,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CompletedCheckpoint> |
JobMaster.triggerCheckpoint(CheckpointType checkpointType,
Time timeout) |
CompletableFuture<CompletedCheckpoint> |
JobMasterGateway.triggerCheckpoint(CheckpointType checkpointType,
Time timeout)
Triggers taking a checkpoint of the executed job.
|
Modifier and Type | Method and Description |
---|---|
CheckpointType |
CheckpointTriggerRequestBody.getCheckpointType() |
Constructor and Description |
---|
CheckpointTriggerRequestBody(CheckpointType checkpointType,
TriggerId triggerId) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CompletedCheckpoint> |
SchedulerNG.triggerCheckpoint(CheckpointType checkpointType) |
CompletableFuture<CompletedCheckpoint> |
SchedulerBase.triggerCheckpoint(CheckpointType checkpointType) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CompletedCheckpoint> |
AdaptiveScheduler.triggerCheckpoint(CheckpointType checkpointType) |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<Acknowledge> |
RestfulGateway.triggerCheckpoint(AsynchronousJobOperationKey operationKey,
CheckpointType checkpointType,
Time timeout)
Triggers a checkpoint with the given savepoint directory as a target.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.