Uses of Class
org.apache.flink.kubernetes.operator.reconciler.SnapshotType
-
Packages that use SnapshotType Package Description org.apache.flink.kubernetes.operator.reconciler org.apache.flink.kubernetes.operator.utils -
-
Uses of SnapshotType in org.apache.flink.kubernetes.operator.reconciler
Methods in org.apache.flink.kubernetes.operator.reconciler that return SnapshotType Modifier and Type Method Description static SnapshotType
SnapshotType. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static SnapshotType[]
SnapshotType. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.flink.kubernetes.operator.reconciler with parameters of type SnapshotType Modifier and Type Method Description static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateLastReconciledSnapshotTriggerNonce(SnapshotInfo snapshotInfo, AbstractFlinkResource<SPEC,?> target, SnapshotType snapshotType)
-
Uses of SnapshotType in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type SnapshotType Modifier and Type Method Description static SnapshotStatus
SnapshotUtils. getLastSnapshotStatus(AbstractFlinkResource<?,?> resource, SnapshotType snapshotType)
protected static java.util.Optional<SnapshotTriggerType>
SnapshotUtils. shouldTriggerSnapshot(AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf, SnapshotType snapshotType)
Checks whether a snapshot should be triggered based on the current status and spec, and if yes, returns the correctSnapshotTriggerType
.static boolean
SnapshotUtils. triggerSnapshotIfNeeded(FlinkService flinkService, AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf, SnapshotType snapshotType)
Triggers any pending manual or periodic snapshots and updates the status accordingly.
-