Uses of Class
org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType
-
Packages that use SnapshotTriggerType Package Description org.apache.flink.kubernetes.operator.api.status org.apache.flink.kubernetes.operator.service org.apache.flink.kubernetes.operator.utils -
-
Uses of SnapshotTriggerType in org.apache.flink.kubernetes.operator.api.status
Methods in org.apache.flink.kubernetes.operator.api.status that return SnapshotTriggerType Modifier and Type Method Description SnapshotTriggerType
CheckpointInfo. getLastTriggerType()
SnapshotTriggerType
SavepointInfo. getLastTriggerType()
SnapshotTriggerType
SnapshotInfo. getLastTriggerType()
SnapshotTriggerType
Snapshot. getTriggerType()
SnapshotTriggerType
SnapshotInfo. getTriggerType()
static SnapshotTriggerType
SnapshotTriggerType. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static SnapshotTriggerType[]
SnapshotTriggerType. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.flink.kubernetes.operator.api.status with parameters of type SnapshotTriggerType Modifier and Type Method Description static Checkpoint
Checkpoint. of(long timeStamp, SnapshotTriggerType triggerType)
static Checkpoint
Checkpoint. of(SnapshotTriggerType triggerType)
static Checkpoint
Checkpoint. of(SnapshotTriggerType triggerType, CheckpointType formatType)
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)
void
CheckpointInfo. setTrigger(java.lang.String triggerId, SnapshotTriggerType triggerType, CheckpointType formatType)
void
SavepointInfo. setTrigger(java.lang.String triggerId, SnapshotTriggerType triggerType, SavepointFormatType formatType)
Constructors in org.apache.flink.kubernetes.operator.api.status with parameters of type SnapshotTriggerType Constructor Description Checkpoint(long timeStamp, SnapshotTriggerType triggerType, CheckpointType formatType, java.lang.Long triggerNonce)
Savepoint(long timeStamp, java.lang.String location, SnapshotTriggerType triggerType, SavepointFormatType formatType, java.lang.Long triggerNonce)
-
Uses of SnapshotTriggerType in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service with parameters of type SnapshotTriggerType Modifier and Type Method Description void
AbstractFlinkService. triggerCheckpoint(java.lang.String jobId, SnapshotTriggerType triggerType, CheckpointInfo checkpointInfo, org.apache.flink.configuration.Configuration conf)
void
FlinkService. triggerCheckpoint(java.lang.String jobId, SnapshotTriggerType triggerType, CheckpointInfo checkpointInfo, org.apache.flink.configuration.Configuration conf)
void
AbstractFlinkService. triggerSavepoint(java.lang.String jobId, SnapshotTriggerType triggerType, SavepointInfo savepointInfo, org.apache.flink.configuration.Configuration conf)
void
FlinkService. triggerSavepoint(java.lang.String jobId, SnapshotTriggerType triggerType, SavepointInfo savepointInfo, org.apache.flink.configuration.Configuration conf)
-
Uses of SnapshotTriggerType in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils that return types with arguments of type SnapshotTriggerType Modifier and Type Method Description 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
.
-