Uses of Class
org.apache.flink.kubernetes.operator.api.status.SavepointInfo
-
Packages that use SavepointInfo Package Description org.apache.flink.kubernetes.operator.reconciler org.apache.flink.kubernetes.operator.service org.apache.flink.kubernetes.operator.utils -
-
Uses of SavepointInfo in org.apache.flink.kubernetes.operator.reconciler
Methods in org.apache.flink.kubernetes.operator.reconciler with parameters of type SavepointInfo Modifier and Type Method Description static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateLastReconciledSavepointTriggerNonce(SavepointInfo savepointInfo, AbstractFlinkResource<SPEC,?> target)
-
Uses of SavepointInfo in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service with parameters of type SavepointInfo Modifier and Type Method Description void
AbstractFlinkService. triggerSavepoint(java.lang.String jobId, SavepointTriggerType triggerType, SavepointInfo savepointInfo, org.apache.flink.configuration.Configuration conf)
void
FlinkService. triggerSavepoint(java.lang.String jobId, SavepointTriggerType triggerType, SavepointInfo savepointInfo, org.apache.flink.configuration.Configuration conf)
-
Uses of SavepointInfo in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type SavepointInfo Modifier and Type Method Description static java.lang.String
SavepointUtils. createSavepointError(SavepointInfo savepointInfo, java.lang.Long triggerNonce)
static boolean
SavepointUtils. gracePeriodEnded(org.apache.flink.configuration.Configuration conf, SavepointInfo savepointInfo)
-