Uses of Class
org.apache.flink.core.execution.SavepointFormatType

Packages that use SavepointFormatType

Package	Description
org.apache.flink.client.cli
org.apache.flink.client.deployment
org.apache.flink.client.deployment.application
org.apache.flink.client.program
org.apache.flink.client.program.rest
org.apache.flink.contrib.streaming.state
org.apache.flink.core.execution
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.rest.messages.job.savepoints
org.apache.flink.runtime.rest.messages.job.savepoints.stop
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.state
org.apache.flink.runtime.state.filesystem
org.apache.flink.runtime.state.hashmap
org.apache.flink.runtime.state.memory
org.apache.flink.runtime.webmonitor
org.apache.flink.state.api.output
org.apache.flink.state.changelog

Uses of SavepointFormatType in org.apache.flink.client.cli

Methods in org.apache.flink.client.cli that return SavepointFormatType

Modifier and Type	Method and Description
SavepointFormatType	CancelOptions.getFormatType()
SavepointFormatType	SavepointOptions.getFormatType()

Uses of SavepointFormatType in org.apache.flink.client.deployment

Methods in org.apache.flink.client.deployment with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	ClusterClientJobClientAdapter.stopWithSavepoint(boolean advanceToEndOfEventTime, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	ClusterClientJobClientAdapter.triggerSavepoint(String savepointDirectory, SavepointFormatType formatType)

Uses of SavepointFormatType in org.apache.flink.client.deployment.application

Methods in org.apache.flink.client.deployment.application with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	WebSubmissionJobClient.stopWithSavepoint(boolean advanceToEndOfEventTime, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	EmbeddedJobClient.stopWithSavepoint(boolean advanceToEndOfEventTime, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	WebSubmissionJobClient.triggerSavepoint(String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	EmbeddedJobClient.triggerSavepoint(String savepointDirectory, SavepointFormatType formatType)

Uses of SavepointFormatType in org.apache.flink.client.program

Methods in org.apache.flink.client.program with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	ClusterClient.cancelWithSavepoint(JobID jobId, String savepointDirectory, SavepointFormatType formatType) Cancels a job identified by the job id and triggers a savepoint.
CompletableFuture<String>	MiniClusterClient.cancelWithSavepoint(JobID jobId, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	ClusterClient.stopWithDetachedSavepoint(JobID jobId, boolean advanceToEndOfEventTime, String savepointDirectory, SavepointFormatType formatType) Stops a program on Flink cluster whose job-manager is configured in this client's configuration.
CompletableFuture<String>	MiniClusterClient.stopWithDetachedSavepoint(JobID jobId, boolean advanceToEndOfEventTime, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	ClusterClient.stopWithSavepoint(JobID jobId, boolean advanceToEndOfEventTime, String savepointDirectory, SavepointFormatType formatType) Stops a program on Flink cluster whose job-manager is configured in this client's configuration.
CompletableFuture<String>	MiniClusterClient.stopWithSavepoint(JobID jobId, boolean advanceToEndOfEventTime, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	ClusterClient.triggerDetachedSavepoint(JobID jobId, String savepointDirectory, SavepointFormatType formatType) Triggers a detached savepoint for the job identified by the job id.
CompletableFuture<String>	MiniClusterClient.triggerDetachedSavepoint(JobID jobId, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	ClusterClient.triggerSavepoint(JobID jobId, String savepointDirectory, SavepointFormatType formatType) Triggers a savepoint for the job identified by the job id.
CompletableFuture<String>	MiniClusterClient.triggerSavepoint(JobID jobId, String savepointDirectory, SavepointFormatType formatType)

Uses of SavepointFormatType in org.apache.flink.client.program.rest

Methods in org.apache.flink.client.program.rest with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	RestClusterClient.cancelWithSavepoint(JobID jobId, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	RestClusterClient.stopWithDetachedSavepoint(JobID jobId, boolean advanceToEndOfTime, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	RestClusterClient.stopWithSavepoint(JobID jobId, boolean advanceToEndOfTime, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	RestClusterClient.stopWithSavepoint(JobID jobId, boolean advanceToEndOfTime, String savepointDirectory, SavepointFormatType formatType, boolean isDetachedMode)
CompletableFuture<String>	RestClusterClient.triggerDetachedSavepoint(JobID jobId, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	RestClusterClient.triggerSavepoint(JobID jobId, String savepointDirectory, SavepointFormatType formatType)

Uses of SavepointFormatType in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state with parameters of type SavepointFormatType

Modifier and Type	Method and Description
boolean	EmbeddedRocksDBStateBackend.supportsSavepointFormat(SavepointFormatType formatType)
boolean	RocksDBStateBackend.supportsSavepointFormat(SavepointFormatType formatType) Deprecated.

Uses of SavepointFormatType in org.apache.flink.core.execution

Fields in org.apache.flink.core.execution declared as SavepointFormatType

Modifier and Type	Field and Description
static SavepointFormatType	SavepointFormatType.DEFAULT

Methods in org.apache.flink.core.execution that return SavepointFormatType

Modifier and Type	Method and Description
static SavepointFormatType	SavepointFormatType.valueOf(String name) Returns the enum constant of this type with the specified name.
static SavepointFormatType[]	SavepointFormatType.values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.flink.core.execution with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	JobClient.stopWithSavepoint(boolean advanceToEndOfEventTime, String savepointDirectory, SavepointFormatType formatType) Stops the associated job on Flink cluster.
CompletableFuture<String>	JobClient.triggerSavepoint(String savepointDirectory, SavepointFormatType formatType) Triggers a savepoint for the associated job.

Uses of SavepointFormatType in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return SavepointFormatType

Modifier and Type	Method and Description
SavepointFormatType	SavepointType.getFormatType()

Methods in org.apache.flink.runtime.checkpoint with parameters of type SavepointFormatType

Modifier and Type	Method and Description
static CheckpointProperties	CheckpointProperties.forSavepoint(boolean forced, SavepointFormatType formatType) Creates the checkpoint properties for a (manually triggered) savepoint.
static CheckpointProperties	CheckpointProperties.forSyncSavepoint(boolean forced, boolean terminate, SavepointFormatType formatType)
static SavepointType	SavepointType.savepoint(SavepointFormatType formatType)
static SavepointType	SavepointType.suspend(SavepointFormatType formatType)
static SavepointType	SavepointType.terminate(SavepointFormatType formatType)
CompletableFuture<CompletedCheckpoint>	CheckpointCoordinator.triggerSavepoint(String targetLocation, SavepointFormatType formatType) Triggers a savepoint with the given savepoint directory as a target.
CompletableFuture<CompletedCheckpoint>	CheckpointCoordinator.triggerSynchronousSavepoint(boolean terminate, String targetLocation, SavepointFormatType formatType) Triggers a synchronous savepoint with the given savepoint directory as a target.

Uses of SavepointFormatType in org.apache.flink.runtime.dispatcher

Methods in org.apache.flink.runtime.dispatcher with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	TriggerSavepointFunction.apply(JobID jobId, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout)
CompletableFuture<Acknowledge>	DispatcherCachedOperationsHandler.stopWithSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout)
CompletableFuture<Acknowledge>	Dispatcher.stopWithSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout)
default CompletableFuture<String>	DispatcherGateway.stopWithSavepointAndGetLocation(JobID jobId, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout) Stops the job with a savepoint, returning a future that completes with the savepoint location when the savepoint is completed.
CompletableFuture<String>	Dispatcher.stopWithSavepointAndGetLocation(JobID jobId, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout)
CompletableFuture<Acknowledge>	DispatcherCachedOperationsHandler.triggerSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout)
CompletableFuture<Acknowledge>	Dispatcher.triggerSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout)
default CompletableFuture<String>	DispatcherGateway.triggerSavepointAndGetLocation(JobID jobId, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout) Triggers a savepoint with the given savepoint directory as a target, returning a future that completes with the savepoint location when it is complete.
CompletableFuture<String>	Dispatcher.triggerSavepointAndGetLocation(JobID jobId, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout)

Uses of SavepointFormatType in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	JobMaster.stopWithSavepoint(String targetDirectory, SavepointFormatType formatType, boolean terminate, Time timeout)
CompletableFuture<String>	JobMasterGateway.stopWithSavepoint(String targetDirectory, SavepointFormatType formatType, boolean terminate, Time timeout) Stops the job with a savepoint.
CompletableFuture<String>	JobMaster.triggerSavepoint(String targetDirectory, boolean cancelJob, SavepointFormatType formatType, Time timeout)
CompletableFuture<String>	JobMasterGateway.triggerSavepoint(String targetDirectory, boolean cancelJob, SavepointFormatType formatType, Time timeout) Triggers taking a savepoint of the executed job.

Uses of SavepointFormatType in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	MiniCluster.stopWithDetachedSavepoint(JobID jobId, String targetDirectory, boolean terminate, SavepointFormatType formatType)
CompletableFuture<String>	MiniClusterJobClient.stopWithSavepoint(boolean terminate, String savepointDirectory, SavepointFormatType formatType)
CompletableFuture<String>	MiniCluster.stopWithSavepoint(JobID jobId, String targetDirectory, boolean terminate, SavepointFormatType formatType)
CompletableFuture<String>	MiniCluster.triggerDetachedSavepoint(JobID jobId, String targetDirectory, boolean cancelJob, SavepointFormatType formatType)
CompletableFuture<String>	MiniCluster.triggerSavepoint(JobID jobId, String targetDirectory, boolean cancelJob, SavepointFormatType formatType)
CompletableFuture<String>	MiniClusterJobClient.triggerSavepoint(String savepointDirectory, SavepointFormatType formatType)

Uses of SavepointFormatType in org.apache.flink.runtime.rest.messages.job.savepoints

Methods in org.apache.flink.runtime.rest.messages.job.savepoints that return SavepointFormatType

Modifier and Type	Method and Description
SavepointFormatType	SavepointTriggerRequestBody.getFormatType()

Constructors in org.apache.flink.runtime.rest.messages.job.savepoints with parameters of type SavepointFormatType

Constructor and Description
SavepointTriggerRequestBody(String targetDirectory, Boolean cancelJob, SavepointFormatType formatType, TriggerId triggerId)

Uses of SavepointFormatType in org.apache.flink.runtime.rest.messages.job.savepoints.stop

Methods in org.apache.flink.runtime.rest.messages.job.savepoints.stop that return SavepointFormatType

Modifier and Type	Method and Description
SavepointFormatType	StopWithSavepointRequestBody.getFormatType()

Constructors in org.apache.flink.runtime.rest.messages.job.savepoints.stop with parameters of type SavepointFormatType

Constructor and Description
StopWithSavepointRequestBody(String targetDirectory, Boolean drain, SavepointFormatType formatType, TriggerId triggerId)

Uses of SavepointFormatType in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	SchedulerBase.stopWithSavepoint(String targetDirectory, boolean terminate, SavepointFormatType formatType)
CompletableFuture<String>	SchedulerNG.stopWithSavepoint(String targetDirectory, boolean terminate, SavepointFormatType formatType)
CompletableFuture<String>	SchedulerBase.triggerSavepoint(String targetDirectory, boolean cancelJob, SavepointFormatType formatType)
CompletableFuture<String>	SchedulerNG.triggerSavepoint(String targetDirectory, boolean cancelJob, SavepointFormatType formatType)

Uses of SavepointFormatType in org.apache.flink.runtime.scheduler.adaptive

Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type SavepointFormatType

Modifier and Type	Method and Description
CompletableFuture<String>	AdaptiveScheduler.stopWithSavepoint(String targetDirectory, boolean terminate, SavepointFormatType formatType)
CompletableFuture<String>	AdaptiveScheduler.triggerSavepoint(String targetDirectory, boolean cancelJob, SavepointFormatType formatType)

Uses of SavepointFormatType in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state with parameters of type SavepointFormatType

Modifier and Type	Method and Description
default boolean	StateBackend.supportsSavepointFormat(SavepointFormatType formatType)

Uses of SavepointFormatType in org.apache.flink.runtime.state.filesystem

Methods in org.apache.flink.runtime.state.filesystem with parameters of type SavepointFormatType

Modifier and Type	Method and Description
boolean	FsStateBackend.supportsSavepointFormat(SavepointFormatType formatType) Deprecated.

Uses of SavepointFormatType in org.apache.flink.runtime.state.hashmap

Methods in org.apache.flink.runtime.state.hashmap with parameters of type SavepointFormatType

Modifier and Type	Method and Description
boolean	HashMapStateBackend.supportsSavepointFormat(SavepointFormatType formatType)

Uses of SavepointFormatType in org.apache.flink.runtime.state.memory

Methods in org.apache.flink.runtime.state.memory with parameters of type SavepointFormatType

Modifier and Type	Method and Description
boolean	MemoryStateBackend.supportsSavepointFormat(SavepointFormatType formatType) Deprecated.

Uses of SavepointFormatType in org.apache.flink.runtime.webmonitor

Methods in org.apache.flink.runtime.webmonitor with parameters of type SavepointFormatType

Modifier and Type	Method and Description
default CompletableFuture<Acknowledge>	RestfulGateway.stopWithSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout) Stops the job with a savepoint, returning a future that completes when the operation is started.
default CompletableFuture<Acknowledge>	RestfulGateway.triggerSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout) Triggers a savepoint with the given savepoint directory as a target, returning a future that completes when the operation is started.

Uses of SavepointFormatType in org.apache.flink.state.api.output

Methods in org.apache.flink.state.api.output with parameters of type SavepointFormatType

Modifier and Type	Method and Description
static <OUT,OP extends StreamOperator<OUT>> TaggedOperatorSubtaskState	SnapshotUtils.snapshot(OP operator, int index, long timestamp, boolean isExactlyOnceMode, boolean isUnalignedCheckpoint, Configuration configuration, Path savepointPath, SavepointFormatType savepointFormatType)

Uses of SavepointFormatType in org.apache.flink.state.changelog

Methods in org.apache.flink.state.changelog with parameters of type SavepointFormatType

Modifier and Type	Method and Description
boolean	AbstractChangelogStateBackend.supportsSavepointFormat(SavepointFormatType formatType)