com.amazonaws.services.kinesisanalyticsv2.model

Class CheckpointConfigurationDescription

java.lang.Object

com.amazonaws.services.kinesisanalyticsv2.model.CheckpointConfigurationDescription

All Implemented Interfaces:

StructuredPojo, Serializable, Cloneable

@Generated(value="com.amazonaws:aws-java-sdk-code-generator")
public class CheckpointConfigurationDescription
extends Object
implements Serializable, Cloneable, StructuredPojo

Describes checkpointing parameters for a Managed Service for Apache Flink application.

See Also:

AWS API Documentation, Serialized Form

Constructor Summary

Constructors

Constructor and Description
CheckpointConfigurationDescription()

Method Summary

Modifier and Type	Method and Description
CheckpointConfigurationDescription	clone()
boolean	equals(Object obj)
Boolean	getCheckpointingEnabled() Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
Long	getCheckpointInterval() Describes the interval in milliseconds between checkpoint operations.
String	getConfigurationType() Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.
Long	getMinPauseBetweenCheckpoints() Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
int	hashCode()
Boolean	isCheckpointingEnabled() Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
void	marshall(ProtocolMarshaller protocolMarshaller) Marshalls this structured data using the given ProtocolMarshaller.
void	setCheckpointingEnabled(Boolean checkpointingEnabled) Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
void	setCheckpointInterval(Long checkpointInterval) Describes the interval in milliseconds between checkpoint operations.
void	setConfigurationType(String configurationType) Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.
void	setMinPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints) Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
String	toString() Returns a string representation of this object.
CheckpointConfigurationDescription	withCheckpointingEnabled(Boolean checkpointingEnabled) Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.
CheckpointConfigurationDescription	withCheckpointInterval(Long checkpointInterval) Describes the interval in milliseconds between checkpoint operations.
CheckpointConfigurationDescription	withConfigurationType(ConfigurationType configurationType) Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.
CheckpointConfigurationDescription	withConfigurationType(String configurationType) Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.
CheckpointConfigurationDescription	withMinPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints) Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

CheckpointConfigurationDescription

public CheckpointConfigurationDescription()

Method Detail

setConfigurationType

public void setConfigurationType(String configurationType)

Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.

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

Parameters:

configurationType - Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.

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:

ConfigurationType

getConfigurationType

public String getConfigurationType()

Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.

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

Returns:

Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.

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:

ConfigurationType

withConfigurationType

public CheckpointConfigurationDescription withConfigurationType(String configurationType)

Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.

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

Parameters:

configurationType - Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.

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

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

ConfigurationType

withConfigurationType

public CheckpointConfigurationDescription withConfigurationType(ConfigurationType configurationType)

Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.

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

Parameters:

configurationType - Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.

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

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

ConfigurationType

setCheckpointingEnabled

public void setCheckpointingEnabled(Boolean checkpointingEnabled)

Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointingEnabled value of true, even if this value is set to another value using this API or in application code.

Parameters:

checkpointingEnabled - Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointingEnabled value of true, even if this value is set to another value using this API or in application code.

getCheckpointingEnabled

public Boolean getCheckpointingEnabled()

Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointingEnabled value of true, 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 is DEFAULT, the application will use a CheckpointingEnabled value of true, even if this value is set to another value using this API or in application code.

withCheckpointingEnabled

public CheckpointConfigurationDescription withCheckpointingEnabled(Boolean checkpointingEnabled)

Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointingEnabled value of true, even if this value is set to another value using this API or in application code.

Parameters:

checkpointingEnabled - Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointingEnabled value of true, even if this value is set to another value using this API or in application code.

Returns:

Returns a reference to this object so that method calls can be chained together.

isCheckpointingEnabled

public Boolean isCheckpointingEnabled()

Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointingEnabled value of true, 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 is DEFAULT, the application will use a CheckpointingEnabled value of true, even if this value is set to another value using this API or in application code.

setCheckpointInterval

public void setCheckpointInterval(Long checkpointInterval)

Describes the interval in milliseconds between checkpoint operations.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointInterval value of 60000, even if this value is set to another value using this API or in application code.

Parameters:

checkpointInterval - Describes the interval in milliseconds between checkpoint operations.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointInterval value of 60000, even if this value is set to another value using this API or in application code.

getCheckpointInterval

public Long getCheckpointInterval()

Describes the interval in milliseconds between checkpoint operations.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointInterval 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 is DEFAULT, the application will use a CheckpointInterval value of 60000, even if this value is set to another value using this API or in application code.

withCheckpointInterval

public CheckpointConfigurationDescription withCheckpointInterval(Long checkpointInterval)

Describes the interval in milliseconds between checkpoint operations.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointInterval value of 60000, even if this value is set to another value using this API or in application code.

Parameters:

checkpointInterval - Describes the interval in milliseconds between checkpoint operations.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointInterval value of 60000, even if this value is set to another value using this API or in application code.

Returns:

Returns a reference to this object so that method calls can be chained together.

setMinPauseBetweenCheckpoints

public void setMinPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints)

Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a MinPauseBetweenCheckpoints value of 5000, even if this value is set using this API or in application code.

Parameters:

minPauseBetweenCheckpoints - Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a MinPauseBetweenCheckpoints value of 5000, even if this value is set using this API or in application code.

getMinPauseBetweenCheckpoints

public Long getMinPauseBetweenCheckpoints()

Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a MinPauseBetweenCheckpoints 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 CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a MinPauseBetweenCheckpoints value of 5000, even if this value is set using this API or in application code.

withMinPauseBetweenCheckpoints

public CheckpointConfigurationDescription withMinPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints)

Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a MinPauseBetweenCheckpoints value of 5000, even if this value is set using this API or in application code.

Parameters:

minPauseBetweenCheckpoints - Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.

If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a MinPauseBetweenCheckpoints value of 5000, even if this value is set using this API or in application code.

Returns:

Returns a reference to this object so that method calls can be chained together.

toString

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

Overrides:

toString in class Object

Returns:

A string representation of this object.

See Also:

Object.toString()

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

clone

public CheckpointConfigurationDescription clone()

Overrides:

clone in class Object

marshall

public void marshall(ProtocolMarshaller protocolMarshaller)

Description copied from interface: StructuredPojo

Marshalls this structured data using the given ProtocolMarshaller.

Specified by:

marshall in interface StructuredPojo

Parameters:

protocolMarshaller - Implementation of ProtocolMarshaller used to marshall this object's data.