/* * 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 updates to the checkpointing parameters for a Flink-based Kinesis Data Analytics application. *

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

* Describes updates to whether the application uses the default checkpointing behavior of Kinesis Data Analytics. * You must set this property to CUSTOM in order to set the CheckpointingEnabled, * CheckpointInterval, or MinPauseBetweenCheckpoints 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 *
*

* */ private String configurationTypeUpdate; /** *

* Describes updates to whether checkpointing is enabled for an 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 checkpointingEnabledUpdate; /** *

* Describes updates to 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 checkpointIntervalUpdate; /** *

* Describes updates to 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 minPauseBetweenCheckpointsUpdate; /** *

* *

* 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 configurationTypeUpdate * Describes updates to whether the application uses the default checkpointing behavior of Kinesis Data * Analytics. You must set this property to CUSTOM in order to set the * CheckpointingEnabled, CheckpointInterval, or * MinPauseBetweenCheckpoints 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 ConfigurationType */ public void setConfigurationTypeUpdate(String configurationTypeUpdate) { this.configurationTypeUpdate = configurationTypeUpdate; } /** *

* *

* 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 updates to whether the application uses the default checkpointing behavior of Kinesis Data * Analytics. You must set this property to CUSTOM in order to set the * CheckpointingEnabled, CheckpointInterval, or * MinPauseBetweenCheckpoints 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 ConfigurationType */ public String getConfigurationTypeUpdate() { return this.configurationTypeUpdate; } /** *

* *

* 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 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 CheckpointConfigurationUpdate withConfigurationTypeUpdate(String configurationTypeUpdate) { setConfigurationTypeUpdate(configurationTypeUpdate); return this; } /** *

* *

* 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 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 CheckpointConfigurationUpdate withConfigurationTypeUpdate(ConfigurationType configurationTypeUpdate) { this.configurationTypeUpdate = configurationTypeUpdate.toString(); return this; } /** *

* Describes updates to whether checkpointing is enabled for an application. *

* *

* * * @param checkpointingEnabledUpdate * Describes updates to whether checkpointing is enabled for an 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 setCheckpointingEnabledUpdate(Boolean checkpointingEnabledUpdate) { this.checkpointingEnabledUpdate = checkpointingEnabledUpdate; } /** *

* Describes updates to whether checkpointing is enabled for an application. *

* *

* * * @return Describes updates to whether checkpointing is enabled for an application.

*/ public Boolean getCheckpointingEnabledUpdate() { return this.checkpointingEnabledUpdate; } /** *

* Describes updates to whether checkpointing is enabled for an application. *

* *

* * * @param checkpointingEnabledUpdate * Describes updates to whether checkpointing is enabled for an application.

* @return Returns a reference to this object so that method calls can be chained together. */ public CheckpointConfigurationUpdate withCheckpointingEnabledUpdate(Boolean checkpointingEnabledUpdate) { setCheckpointingEnabledUpdate(checkpointingEnabledUpdate); return this; } /** *

* Describes updates to whether checkpointing is enabled for an application. *

* *

* * * @return Describes updates to whether checkpointing is enabled for an application.

*/ public Boolean isCheckpointingEnabledUpdate() { return this.checkpointingEnabledUpdate; } /** *

* Describes updates to the interval in milliseconds between checkpoint operations. *

* *

* * * @param checkpointIntervalUpdate * Describes updates to 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 setCheckpointIntervalUpdate(Long checkpointIntervalUpdate) { this.checkpointIntervalUpdate = checkpointIntervalUpdate; } /** *

* Describes updates to the interval in milliseconds between checkpoint operations. *

* *

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

*/ public Long getCheckpointIntervalUpdate() { return this.checkpointIntervalUpdate; } /** *

* Describes updates to the interval in milliseconds between checkpoint operations. *

* *

* * * @param checkpointIntervalUpdate * Describes updates to the interval in milliseconds between checkpoint operations.

* @return Returns a reference to this object so that method calls can be chained together. */ public CheckpointConfigurationUpdate withCheckpointIntervalUpdate(Long checkpointIntervalUpdate) { setCheckpointIntervalUpdate(checkpointIntervalUpdate); return this; } /** *

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

* *

* * * @param minPauseBetweenCheckpointsUpdate * Describes updates to 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 setMinPauseBetweenCheckpointsUpdate(Long minPauseBetweenCheckpointsUpdate) { this.minPauseBetweenCheckpointsUpdate = minPauseBetweenCheckpointsUpdate; } /** *

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

* *

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

*/ public Long getMinPauseBetweenCheckpointsUpdate() { return this.minPauseBetweenCheckpointsUpdate; } /** *

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

* *

* * * @param minPauseBetweenCheckpointsUpdate * Describes updates to 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 CheckpointConfigurationUpdate withMinPauseBetweenCheckpointsUpdate(Long minPauseBetweenCheckpointsUpdate) { setMinPauseBetweenCheckpointsUpdate(minPauseBetweenCheckpointsUpdate); 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 (getConfigurationTypeUpdate() != null) sb.append("ConfigurationTypeUpdate: ").append(getConfigurationTypeUpdate()).append(","); if (getCheckpointingEnabledUpdate() != null) sb.append("CheckpointingEnabledUpdate: ").append(getCheckpointingEnabledUpdate()).append(","); if (getCheckpointIntervalUpdate() != null) sb.append("CheckpointIntervalUpdate: ").append(getCheckpointIntervalUpdate()).append(","); if (getMinPauseBetweenCheckpointsUpdate() != null) sb.append("MinPauseBetweenCheckpointsUpdate: ").append(getMinPauseBetweenCheckpointsUpdate()); sb.append("}"); return sb.toString(); } @Override public boolean equals(Object obj) { if (this == obj) return true; if (obj == null) return false; if (obj instanceof CheckpointConfigurationUpdate == false) return false; CheckpointConfigurationUpdate other = (CheckpointConfigurationUpdate) obj; if (other.getConfigurationTypeUpdate() == null ^ this.getConfigurationTypeUpdate() == null) return false; if (other.getConfigurationTypeUpdate() != null && other.getConfigurationTypeUpdate().equals(this.getConfigurationTypeUpdate()) == false) return false; if (other.getCheckpointingEnabledUpdate() == null ^ this.getCheckpointingEnabledUpdate() == null) return false; if (other.getCheckpointingEnabledUpdate() != null && other.getCheckpointingEnabledUpdate().equals(this.getCheckpointingEnabledUpdate()) == false) return false; if (other.getCheckpointIntervalUpdate() == null ^ this.getCheckpointIntervalUpdate() == null) return false; if (other.getCheckpointIntervalUpdate() != null && other.getCheckpointIntervalUpdate().equals(this.getCheckpointIntervalUpdate()) == false) return false; if (other.getMinPauseBetweenCheckpointsUpdate() == null ^ this.getMinPauseBetweenCheckpointsUpdate() == null) return false; if (other.getMinPauseBetweenCheckpointsUpdate() != null && other.getMinPauseBetweenCheckpointsUpdate().equals(this.getMinPauseBetweenCheckpointsUpdate()) == false) return false; return true; } @Override public int hashCode() { final int prime = 31; int hashCode = 1; hashCode = prime * hashCode + ((getConfigurationTypeUpdate() == null) ? 0 : getConfigurationTypeUpdate().hashCode()); hashCode = prime * hashCode + ((getCheckpointingEnabledUpdate() == null) ? 0 : getCheckpointingEnabledUpdate().hashCode()); hashCode = prime * hashCode + ((getCheckpointIntervalUpdate() == null) ? 0 : getCheckpointIntervalUpdate().hashCode()); hashCode = prime * hashCode + ((getMinPauseBetweenCheckpointsUpdate() == null) ? 0 : getMinPauseBetweenCheckpointsUpdate().hashCode()); return hashCode; } @Override public CheckpointConfigurationUpdate clone() { try { return (CheckpointConfigurationUpdate) 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.CheckpointConfigurationUpdateMarshaller.getInstance().marshall(this, protocolMarshaller); } }