Uses of Class
org.apache.flink.kubernetes.operator.api.status.Savepoint
-
Packages that use Savepoint Package Description org.apache.flink.kubernetes.operator.api.status org.apache.flink.kubernetes.operator.service -
-
Uses of Savepoint in org.apache.flink.kubernetes.operator.api.status
Methods in org.apache.flink.kubernetes.operator.api.status that return Savepoint Modifier and Type Method Description static Savepoint
Savepoint. of(java.lang.String location, long timeStamp, SnapshotTriggerType triggerType)
static Savepoint
Savepoint. of(java.lang.String location, SnapshotTriggerType triggerType)
static Savepoint
Savepoint. of(java.lang.String location, SnapshotTriggerType triggerType, SavepointFormatType formatType)
Methods in org.apache.flink.kubernetes.operator.api.status with parameters of type Savepoint Modifier and Type Method Description void
SavepointInfo. updateLastSavepoint(Savepoint savepoint)
Update last savepoint info and add the savepoint to the history if it isn't already the most recent savepoint. -
Uses of Savepoint in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service that return types with arguments of type Savepoint Modifier and Type Method Description java.util.Optional<Savepoint>
AbstractFlinkService. getLastCheckpoint(org.apache.flink.api.common.JobID jobId, org.apache.flink.configuration.Configuration conf)
java.util.Optional<Savepoint>
FlinkService. getLastCheckpoint(org.apache.flink.api.common.JobID jobId, org.apache.flink.configuration.Configuration conf)
-