/* * Copyright 2018-2023 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with * the License. A copy of the License is located at * * http://aws.amazon.com/apache2.0 * * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions * and limitations under the License. */ package com.amazonaws.services.kinesisanalyticsv2.model; import java.io.Serializable; import javax.annotation.Generated; import com.amazonaws.protocol.StructuredPojo; import com.amazonaws.protocol.ProtocolMarshaller; /** *

* Describes checkpointing parameters for a Flink-based Kinesis Data Analytics application. *

* * @see AWS API Documentation */ @Generated("com.amazonaws:aws-java-sdk-code-generator") public class CheckpointConfigurationDescription implements Serializable, Cloneable, StructuredPojo { /** *

* Describes whether the application uses the default checkpointing behavior in Kinesis Data Analytics. *

* *

* 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 *
*

* */ private String configurationType; /** *

* Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics 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. *

* */ private Boolean checkpointingEnabled; /** *

* 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. *

* */ private Long checkpointInterval; /** *

* 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. *

* */ private Long minPauseBetweenCheckpoints; /** *

* Describes whether the application uses the default checkpointing behavior in Kinesis Data Analytics. *

* *

* 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 *
*

* * * @param configurationType * Describes whether the application uses the default checkpointing behavior in Kinesis Data Analytics.

* *

* 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 ConfigurationType */ public void setConfigurationType(String configurationType) { this.configurationType = configurationType; } /** *

* Describes whether the application uses the default checkpointing behavior in Kinesis Data Analytics. *

* *

* 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 *
*

* * * @return Describes whether the application uses the default checkpointing behavior in Kinesis Data Analytics.

* *

* 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 ConfigurationType */ public String getConfigurationType() { return this.configurationType; } /** *

* Describes whether the application uses the default checkpointing behavior in Kinesis Data Analytics. *

* *

* 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 *
*

* * * @param configurationType * Describes whether the application uses the default checkpointing behavior in Kinesis Data Analytics.

* *

* 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 *
*

* @return Returns a reference to this object so that method calls can be chained together. * @see ConfigurationType */ public CheckpointConfigurationDescription withConfigurationType(String configurationType) { setConfigurationType(configurationType); return this; } /** *

* Describes whether the application uses the default checkpointing behavior in Kinesis Data Analytics. *

* *

* 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 *
*

* * * @param configurationType * Describes whether the application uses the default checkpointing behavior in Kinesis Data Analytics.

* *

* 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 *
*

* @return Returns a reference to this object so that method calls can be chained together. * @see ConfigurationType */ public CheckpointConfigurationDescription withConfigurationType(ConfigurationType configurationType) { this.configurationType = configurationType.toString(); return this; } /** *

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

* *

* * * @param checkpointingEnabled * Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics 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. *

*/ public void setCheckpointingEnabled(Boolean checkpointingEnabled) { this.checkpointingEnabled = checkpointingEnabled; } /** *

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

* *

* * * @return Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.

* *

*/ public Boolean getCheckpointingEnabled() { return this.checkpointingEnabled; } /** *

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

* *

* * * @param checkpointingEnabled * Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.

* *

* @return Returns a reference to this object so that method calls can be chained together. */ public CheckpointConfigurationDescription withCheckpointingEnabled(Boolean checkpointingEnabled) { setCheckpointingEnabled(checkpointingEnabled); return this; } /** *

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

* *

* * * @return Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.

* *

*/ public Boolean isCheckpointingEnabled() { return this.checkpointingEnabled; } /** *

* Describes the interval in milliseconds between checkpoint operations. *

* *

* * * @param 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. *

*/ public void setCheckpointInterval(Long checkpointInterval) { this.checkpointInterval = checkpointInterval; } /** *

* Describes the interval in milliseconds between checkpoint operations. *

* *

* * * @return Describes the interval in milliseconds between checkpoint operations.

*/ public Long getCheckpointInterval() { return this.checkpointInterval; } /** *

* Describes the interval in milliseconds between checkpoint operations. *

* *

* * * @param checkpointInterval * Describes the interval in milliseconds between checkpoint operations.

* @return Returns a reference to this object so that method calls can be chained together. */ public CheckpointConfigurationDescription withCheckpointInterval(Long checkpointInterval) { setCheckpointInterval(checkpointInterval); return this; } /** *

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

* *

* * * @param 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. *

*/ public void setMinPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints) { this.minPauseBetweenCheckpoints = minPauseBetweenCheckpoints; } /** *

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

* *

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

*/ public Long getMinPauseBetweenCheckpoints() { return this.minPauseBetweenCheckpoints; } /** *

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

* *

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

* @return Returns a reference to this object so that method calls can be chained together. */ public CheckpointConfigurationDescription withMinPauseBetweenCheckpoints(Long minPauseBetweenCheckpoints) { setMinPauseBetweenCheckpoints(minPauseBetweenCheckpoints); return this; } /** * 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. * * @return A string representation of this object. * * @see java.lang.Object#toString() */ @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("{"); if (getConfigurationType() != null) sb.append("ConfigurationType: ").append(getConfigurationType()).append(","); if (getCheckpointingEnabled() != null) sb.append("CheckpointingEnabled: ").append(getCheckpointingEnabled()).append(","); if (getCheckpointInterval() != null) sb.append("CheckpointInterval: ").append(getCheckpointInterval()).append(","); if (getMinPauseBetweenCheckpoints() != null) sb.append("MinPauseBetweenCheckpoints: ").append(getMinPauseBetweenCheckpoints()); sb.append("}"); return sb.toString(); } @Override public boolean equals(Object obj) { if (this == obj) return true; if (obj == null) return false; if (obj instanceof CheckpointConfigurationDescription == false) return false; CheckpointConfigurationDescription other = (CheckpointConfigurationDescription) obj; if (other.getConfigurationType() == null ^ this.getConfigurationType() == null) return false; if (other.getConfigurationType() != null && other.getConfigurationType().equals(this.getConfigurationType()) == false) return false; if (other.getCheckpointingEnabled() == null ^ this.getCheckpointingEnabled() == null) return false; if (other.getCheckpointingEnabled() != null && other.getCheckpointingEnabled().equals(this.getCheckpointingEnabled()) == false) return false; if (other.getCheckpointInterval() == null ^ this.getCheckpointInterval() == null) return false; if (other.getCheckpointInterval() != null && other.getCheckpointInterval().equals(this.getCheckpointInterval()) == false) return false; if (other.getMinPauseBetweenCheckpoints() == null ^ this.getMinPauseBetweenCheckpoints() == null) return false; if (other.getMinPauseBetweenCheckpoints() != null && other.getMinPauseBetweenCheckpoints().equals(this.getMinPauseBetweenCheckpoints()) == false) return false; return true; } @Override public int hashCode() { final int prime = 31; int hashCode = 1; hashCode = prime * hashCode + ((getConfigurationType() == null) ? 0 : getConfigurationType().hashCode()); hashCode = prime * hashCode + ((getCheckpointingEnabled() == null) ? 0 : getCheckpointingEnabled().hashCode()); hashCode = prime * hashCode + ((getCheckpointInterval() == null) ? 0 : getCheckpointInterval().hashCode()); hashCode = prime * hashCode + ((getMinPauseBetweenCheckpoints() == null) ? 0 : getMinPauseBetweenCheckpoints().hashCode()); return hashCode; } @Override public CheckpointConfigurationDescription clone() { try { return (CheckpointConfigurationDescription) super.clone(); } catch (CloneNotSupportedException e) { throw new IllegalStateException("Got a CloneNotSupportedException from Object.clone() " + "even though we're Cloneable!", e); } } @com.amazonaws.annotation.SdkInternalApi @Override public void marshall(ProtocolMarshaller protocolMarshaller) { com.amazonaws.services.kinesisanalyticsv2.model.transform.CheckpointConfigurationDescriptionMarshaller.getInstance().marshall(this, protocolMarshaller); } }