Uses of Class
org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType
-
Packages that use SavepointTriggerType Package Description org.apache.flink.kubernetes.operator.api.status org.apache.flink.kubernetes.operator.service org.apache.flink.kubernetes.operator.utils -
-
Uses of SavepointTriggerType in org.apache.flink.kubernetes.operator.api.status
Methods in org.apache.flink.kubernetes.operator.api.status that return SavepointTriggerType Modifier and Type Method Description static SavepointTriggerType
SavepointTriggerType. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static SavepointTriggerType[]
SavepointTriggerType. 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 SavepointTriggerType Modifier and Type Method Description static Savepoint
Savepoint. of(java.lang.String location, long timeStamp, SavepointTriggerType triggerType)
static Savepoint
Savepoint. of(java.lang.String location, SavepointTriggerType triggerType)
static Savepoint
Savepoint. of(java.lang.String location, SavepointTriggerType triggerType, SavepointFormatType formatType)
void
SavepointInfo. setTrigger(java.lang.String triggerId, SavepointTriggerType triggerType, SavepointFormatType formatType)
Constructors in org.apache.flink.kubernetes.operator.api.status with parameters of type SavepointTriggerType Constructor Description Savepoint(long timeStamp, java.lang.String location, SavepointTriggerType triggerType, SavepointFormatType formatType, java.lang.Long triggerNonce)
-
Uses of SavepointTriggerType in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service with parameters of type SavepointTriggerType 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 SavepointTriggerType in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils that return types with arguments of type SavepointTriggerType Modifier and Type Method Description protected static java.util.Optional<SavepointTriggerType>
SavepointUtils. shouldTriggerSavepoint(AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf)
Checks whether savepoint should be triggered based on the current status and spec and if yes, returns the correctSavepointTriggerType
.
-