Class CheckpointConfiguration
- All Implemented Interfaces:
Serializable
,SdkPojo
,ToCopyableBuilder<CheckpointConfiguration.Builder,
CheckpointConfiguration>
Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.
- See Also:
-
Nested Class Summary
-
Method Summary
Modifier and TypeMethodDescriptionbuilder()
final Boolean
Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.final Long
Describes the interval in milliseconds between checkpoint operations.final ConfigurationType
Describes whether the application uses Managed Service for Apache Flink' default checkpointing behavior.final String
Describes whether the application uses Managed Service for Apache Flink' default checkpointing behavior.final boolean
final boolean
equalsBySdkFields
(Object obj) Indicates whether some other object is "equal to" this one by SDK fields.final <T> Optional
<T> getValueForField
(String fieldName, Class<T> clazz) final int
hashCode()
final Long
Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.static Class
<? extends CheckpointConfiguration.Builder> Take this object and create a builder that contains all of the current property values of this object.final String
toString()
Returns a string representation of this object.Methods inherited from interface software.amazon.awssdk.utils.builder.ToCopyableBuilder
copy
-
Method Details
-
configurationType
Describes whether the application uses Managed Service for Apache Flink' default checkpointing behavior. You must set this property to
CUSTOM
in order to set theCheckpointingEnabled
,CheckpointInterval
, orMinPauseBetweenCheckpoints
parameters.If this value is set to
DEFAULT
, the application will use the following values, even if they are set to other values using APIs or application code:-
CheckpointingEnabled: true
-
CheckpointInterval: 60000
-
MinPauseBetweenCheckpoints: 5000
If the service returns an enum value that is not available in the current SDK version,
configurationType
will returnConfigurationType.UNKNOWN_TO_SDK_VERSION
. The raw value returned by the service is available fromconfigurationTypeAsString()
.- Returns:
- Describes whether the application uses Managed Service for Apache Flink' default checkpointing behavior.
You must set this property to
CUSTOM
in order to set theCheckpointingEnabled
,CheckpointInterval
, orMinPauseBetweenCheckpoints
parameters.If this value is set to
DEFAULT
, the application will use the following values, even if they are set to other values using APIs or application code:-
CheckpointingEnabled: true
-
CheckpointInterval: 60000
-
MinPauseBetweenCheckpoints: 5000
-
- See Also:
-
-
configurationTypeAsString
Describes whether the application uses Managed Service for Apache Flink' default checkpointing behavior. You must set this property to
CUSTOM
in order to set theCheckpointingEnabled
,CheckpointInterval
, orMinPauseBetweenCheckpoints
parameters.If this value is set to
DEFAULT
, the application will use the following values, even if they are set to other values using APIs or application code:-
CheckpointingEnabled: true
-
CheckpointInterval: 60000
-
MinPauseBetweenCheckpoints: 5000
If the service returns an enum value that is not available in the current SDK version,
configurationType
will returnConfigurationType.UNKNOWN_TO_SDK_VERSION
. The raw value returned by the service is available fromconfigurationTypeAsString()
.- Returns:
- Describes whether the application uses Managed Service for Apache Flink' default checkpointing behavior.
You must set this property to
CUSTOM
in order to set theCheckpointingEnabled
,CheckpointInterval
, orMinPauseBetweenCheckpoints
parameters.If this value is set to
DEFAULT
, the application will use the following values, even if they are set to other values using APIs or application code:-
CheckpointingEnabled: true
-
CheckpointInterval: 60000
-
MinPauseBetweenCheckpoints: 5000
-
- See Also:
-
-
checkpointingEnabled
Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
If
CheckpointConfiguration.ConfigurationType
isDEFAULT
, the application will use aCheckpointingEnabled
value oftrue
, even if this value is set to another value using this API or in application code.- Returns:
- Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
If
CheckpointConfiguration.ConfigurationType
isDEFAULT
, the application will use aCheckpointingEnabled
value oftrue
, even if this value is set to another value using this API or in application code.
-
checkpointInterval
Describes the interval in milliseconds between checkpoint operations.
If
CheckpointConfiguration.ConfigurationType
isDEFAULT
, the application will use aCheckpointInterval
value of 60000, even if this value is set to another value using this API or in application code.- Returns:
- Describes the interval in milliseconds between checkpoint operations.
If
CheckpointConfiguration.ConfigurationType
isDEFAULT
, the application will use aCheckpointInterval
value of 60000, even if this value is set to another value using this API or in application code.
-
minPauseBetweenCheckpoints
Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start. If a checkpoint operation takes longer than the
CheckpointInterval
, the application otherwise performs continual checkpoint operations. For more information, see Tuning Checkpointing in the Apache Flink Documentation.If
CheckpointConfiguration.ConfigurationType
isDEFAULT
, the application will use aMinPauseBetweenCheckpoints
value of 5000, even if this value is set using this API or in application code.- Returns:
- Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint
operation can start. If a checkpoint operation takes longer than the
CheckpointInterval
, the application otherwise performs continual checkpoint operations. For more information, see Tuning Checkpointing in the Apache Flink Documentation.If
CheckpointConfiguration.ConfigurationType
isDEFAULT
, the application will use aMinPauseBetweenCheckpoints
value of 5000, even if this value is set using this API or in application code.
-
toBuilder
Description copied from interface:ToCopyableBuilder
Take this object and create a builder that contains all of the current property values of this object.- Specified by:
toBuilder
in interfaceToCopyableBuilder<CheckpointConfiguration.Builder,
CheckpointConfiguration> - Returns:
- a builder for type T
-
builder
-
serializableBuilderClass
-
hashCode
public final int hashCode() -
equals
-
equalsBySdkFields
Description copied from interface:SdkPojo
Indicates whether some other object is "equal to" this one by SDK fields. An SDK field is a modeled, non-inherited field in anSdkPojo
class, and is generated based on a service model.If an
SdkPojo
class does not have any inherited fields,equalsBySdkFields
andequals
are essentially the same.- Specified by:
equalsBySdkFields
in interfaceSdkPojo
- Parameters:
obj
- the object to be compared with- Returns:
- true if the other object equals to this object by sdk fields, false otherwise.
-
toString
Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be redacted from this string using a placeholder value. -
getValueForField
-
sdkFields
-