software.amazon.awssdk.services.kinesisanalyticsv2.model

Class CheckpointConfiguration

java.lang.Object

software.amazon.awssdk.services.kinesisanalyticsv2.model.CheckpointConfiguration

All Implemented Interfaces:

Serializable, SdkPojo, ToCopyableBuilder<CheckpointConfiguration.Builder,CheckpointConfiguration>

@Generated(value="software.amazon.awssdk:codegen")
public final class CheckpointConfiguration
extends Object
implements SdkPojo, Serializable, 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:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CheckpointConfiguration.Builder

Method Summary

Modifier and Type	Method and Description
static CheckpointConfiguration.Builder	builder()
Boolean	checkpointingEnabled() Describes whether checkpointing is enabled for a Java-based Kinesis Data Analytics application.
Long	checkpointInterval() Describes the interval in milliseconds between checkpoint operations.
ConfigurationType	configurationType() Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.
String	configurationTypeAsString() Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.
boolean	equals(Object obj)
<T> Optional<T>	getValueForField(String fieldName, Class<T> clazz)
int	hashCode()
Long	minPauseBetweenCheckpoints() Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
List<SdkField<?>>	sdkFields()
static Class<? extends CheckpointConfiguration.Builder>	serializableBuilderClass()
CheckpointConfiguration.Builder	toBuilder() Take this object and create a builder that contains all of the current property values of this object.
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface software.amazon.awssdk.utils.builder.ToCopyableBuilder

copy

Method Detail

configurationType

public ConfigurationType configurationType()

Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.

If the service returns an enum value that is not available in the current SDK version, configurationType will return ConfigurationType.UNKNOWN_TO_SDK_VERSION. The raw value returned by the service is available from configurationTypeAsString().

Returns:

Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.

See Also:

ConfigurationType

configurationTypeAsString

public String configurationTypeAsString()

Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.

If the service returns an enum value that is not available in the current SDK version, configurationType will return ConfigurationType.UNKNOWN_TO_SDK_VERSION. The raw value returned by the service is available from configurationTypeAsString().

Returns:

Describes whether the application uses Amazon Kinesis Data Analytics' default checkpointing behavior.

See Also:

ConfigurationType

checkpointingEnabled

public Boolean checkpointingEnabled()

Describes whether checkpointing is enabled for a Java-based Kinesis Data Analytics application.

Returns:

Describes whether checkpointing is enabled for a Java-based Kinesis Data Analytics application.

checkpointInterval

public Long checkpointInterval()

Describes the interval in milliseconds between checkpoint operations.

Returns:

Describes the interval in milliseconds between checkpoint operations.

minPauseBetweenCheckpoints

public Long 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.

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.

toBuilder

public CheckpointConfiguration.Builder 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 interface ToCopyableBuilder<CheckpointConfiguration.Builder,CheckpointConfiguration>

Returns:

a builder for type T

builder

public static CheckpointConfiguration.Builder builder()

serializableBuilderClass

public static Class<? extends CheckpointConfiguration.Builder> serializableBuilderClass()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

getValueForField

public <T> Optional<T> getValueForField(String fieldName,
                                        Class<T> clazz)

sdkFields

public List<SdkField<?>> sdkFields()

Specified by:

sdkFields in interface SdkPojo

Returns:

List of SdkField in this POJO. May be empty list but should never be null.