/** * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * SPDX-License-Identifier: Apache-2.0. */ #pragma once #include #include #include #include #include namespace Aws { namespace Utils { namespace Json { class JsonValue; class JsonView; } // namespace Json } // namespace Utils namespace KinesisAnalyticsV2 { namespace Model { /** *

Describes configuration parameters for a Flink-based Kinesis Data Analytics * application or a Studio notebook.

See Also:

AWS * API Reference

*/ class FlinkApplicationConfiguration { public: AWS_KINESISANALYTICSV2_API FlinkApplicationConfiguration(); AWS_KINESISANALYTICSV2_API FlinkApplicationConfiguration(Aws::Utils::Json::JsonView jsonValue); AWS_KINESISANALYTICSV2_API FlinkApplicationConfiguration& operator=(Aws::Utils::Json::JsonView jsonValue); AWS_KINESISANALYTICSV2_API Aws::Utils::Json::JsonValue Jsonize() const; /** *

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.

*/ inline const CheckpointConfiguration& GetCheckpointConfiguration() const{ return m_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.

*/ inline bool CheckpointConfigurationHasBeenSet() const { return m_checkpointConfigurationHasBeenSet; } /** *

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.

*/ inline void SetCheckpointConfiguration(const CheckpointConfiguration& value) { m_checkpointConfigurationHasBeenSet = true; m_checkpointConfiguration = value; } /** *

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.

*/ inline void SetCheckpointConfiguration(CheckpointConfiguration&& value) { m_checkpointConfigurationHasBeenSet = true; m_checkpointConfiguration = std::move(value); } /** *

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.

*/ inline FlinkApplicationConfiguration& WithCheckpointConfiguration(const CheckpointConfiguration& value) { SetCheckpointConfiguration(value); return *this;} /** *

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.

*/ inline FlinkApplicationConfiguration& WithCheckpointConfiguration(CheckpointConfiguration&& value) { SetCheckpointConfiguration(std::move(value)); return *this;} /** *

Describes configuration parameters for Amazon CloudWatch logging for an * application.

*/ inline const MonitoringConfiguration& GetMonitoringConfiguration() const{ return m_monitoringConfiguration; } /** *

Describes configuration parameters for Amazon CloudWatch logging for an * application.

*/ inline bool MonitoringConfigurationHasBeenSet() const { return m_monitoringConfigurationHasBeenSet; } /** *

Describes configuration parameters for Amazon CloudWatch logging for an * application.

*/ inline void SetMonitoringConfiguration(const MonitoringConfiguration& value) { m_monitoringConfigurationHasBeenSet = true; m_monitoringConfiguration = value; } /** *

Describes configuration parameters for Amazon CloudWatch logging for an * application.

*/ inline void SetMonitoringConfiguration(MonitoringConfiguration&& value) { m_monitoringConfigurationHasBeenSet = true; m_monitoringConfiguration = std::move(value); } /** *

Describes configuration parameters for Amazon CloudWatch logging for an * application.

*/ inline FlinkApplicationConfiguration& WithMonitoringConfiguration(const MonitoringConfiguration& value) { SetMonitoringConfiguration(value); return *this;} /** *

Describes configuration parameters for Amazon CloudWatch logging for an * application.

*/ inline FlinkApplicationConfiguration& WithMonitoringConfiguration(MonitoringConfiguration&& value) { SetMonitoringConfiguration(std::move(value)); return *this;} /** *

Describes parameters for how an application executes multiple tasks * simultaneously.

*/ inline const ParallelismConfiguration& GetParallelismConfiguration() const{ return m_parallelismConfiguration; } /** *

Describes parameters for how an application executes multiple tasks * simultaneously.

*/ inline bool ParallelismConfigurationHasBeenSet() const { return m_parallelismConfigurationHasBeenSet; } /** *

Describes parameters for how an application executes multiple tasks * simultaneously.

*/ inline void SetParallelismConfiguration(const ParallelismConfiguration& value) { m_parallelismConfigurationHasBeenSet = true; m_parallelismConfiguration = value; } /** *

Describes parameters for how an application executes multiple tasks * simultaneously.

*/ inline void SetParallelismConfiguration(ParallelismConfiguration&& value) { m_parallelismConfigurationHasBeenSet = true; m_parallelismConfiguration = std::move(value); } /** *

Describes parameters for how an application executes multiple tasks * simultaneously.

*/ inline FlinkApplicationConfiguration& WithParallelismConfiguration(const ParallelismConfiguration& value) { SetParallelismConfiguration(value); return *this;} /** *

Describes parameters for how an application executes multiple tasks * simultaneously.

*/ inline FlinkApplicationConfiguration& WithParallelismConfiguration(ParallelismConfiguration&& value) { SetParallelismConfiguration(std::move(value)); return *this;} private: CheckpointConfiguration m_checkpointConfiguration; bool m_checkpointConfigurationHasBeenSet = false; MonitoringConfiguration m_monitoringConfiguration; bool m_monitoringConfigurationHasBeenSet = false; ParallelismConfiguration m_parallelismConfiguration; bool m_parallelismConfigurationHasBeenSet = false; }; } // namespace Model } // namespace KinesisAnalyticsV2 } // namespace Aws