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

Describes parameters for how a Flink-based Kinesis Data Analytics application * executes multiple tasks simultaneously.

See Also:

AWS * API Reference

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

Describes whether the application uses the default parallelism for the * Kinesis Data Analytics service.

*/ inline const ConfigurationType& GetConfigurationType() const{ return m_configurationType; } /** *

Describes whether the application uses the default parallelism for the * Kinesis Data Analytics service.

*/ inline bool ConfigurationTypeHasBeenSet() const { return m_configurationTypeHasBeenSet; } /** *

Describes whether the application uses the default parallelism for the * Kinesis Data Analytics service.

*/ inline void SetConfigurationType(const ConfigurationType& value) { m_configurationTypeHasBeenSet = true; m_configurationType = value; } /** *

Describes whether the application uses the default parallelism for the * Kinesis Data Analytics service.

*/ inline void SetConfigurationType(ConfigurationType&& value) { m_configurationTypeHasBeenSet = true; m_configurationType = std::move(value); } /** *

Describes whether the application uses the default parallelism for the * Kinesis Data Analytics service.

*/ inline ParallelismConfigurationDescription& WithConfigurationType(const ConfigurationType& value) { SetConfigurationType(value); return *this;} /** *

Describes whether the application uses the default parallelism for the * Kinesis Data Analytics service.

*/ inline ParallelismConfigurationDescription& WithConfigurationType(ConfigurationType&& value) { SetConfigurationType(std::move(value)); return *this;} /** *

Describes the initial number of parallel tasks that a Flink-based Kinesis * Data Analytics application can perform. If AutoScalingEnabled is * set to True, then Kinesis Data Analytics can increase the * CurrentParallelism value in response to application load. The * service can increase CurrentParallelism up to the maximum * parallelism, which is ParalellismPerKPU times the maximum KPUs for * the application. The maximum KPUs for an application is 32 by default, and can * be increased by requesting a limit increase. If application load is reduced, the * service can reduce the CurrentParallelism value down to the * Parallelism setting.

*/ inline int GetParallelism() const{ return m_parallelism; } /** *

Describes the initial number of parallel tasks that a Flink-based Kinesis * Data Analytics application can perform. If AutoScalingEnabled is * set to True, then Kinesis Data Analytics can increase the * CurrentParallelism value in response to application load. The * service can increase CurrentParallelism up to the maximum * parallelism, which is ParalellismPerKPU times the maximum KPUs for * the application. The maximum KPUs for an application is 32 by default, and can * be increased by requesting a limit increase. If application load is reduced, the * service can reduce the CurrentParallelism value down to the * Parallelism setting.

*/ inline bool ParallelismHasBeenSet() const { return m_parallelismHasBeenSet; } /** *

Describes the initial number of parallel tasks that a Flink-based Kinesis * Data Analytics application can perform. If AutoScalingEnabled is * set to True, then Kinesis Data Analytics can increase the * CurrentParallelism value in response to application load. The * service can increase CurrentParallelism up to the maximum * parallelism, which is ParalellismPerKPU times the maximum KPUs for * the application. The maximum KPUs for an application is 32 by default, and can * be increased by requesting a limit increase. If application load is reduced, the * service can reduce the CurrentParallelism value down to the * Parallelism setting.

*/ inline void SetParallelism(int value) { m_parallelismHasBeenSet = true; m_parallelism = value; } /** *

Describes the initial number of parallel tasks that a Flink-based Kinesis * Data Analytics application can perform. If AutoScalingEnabled is * set to True, then Kinesis Data Analytics can increase the * CurrentParallelism value in response to application load. The * service can increase CurrentParallelism up to the maximum * parallelism, which is ParalellismPerKPU times the maximum KPUs for * the application. The maximum KPUs for an application is 32 by default, and can * be increased by requesting a limit increase. If application load is reduced, the * service can reduce the CurrentParallelism value down to the * Parallelism setting.

*/ inline ParallelismConfigurationDescription& WithParallelism(int value) { SetParallelism(value); return *this;} /** *

Describes the number of parallel tasks that a Flink-based Kinesis Data * Analytics application can perform per Kinesis Processing Unit (KPU) used by the * application.

*/ inline int GetParallelismPerKPU() const{ return m_parallelismPerKPU; } /** *

Describes the number of parallel tasks that a Flink-based Kinesis Data * Analytics application can perform per Kinesis Processing Unit (KPU) used by the * application.

*/ inline bool ParallelismPerKPUHasBeenSet() const { return m_parallelismPerKPUHasBeenSet; } /** *

Describes the number of parallel tasks that a Flink-based Kinesis Data * Analytics application can perform per Kinesis Processing Unit (KPU) used by the * application.

*/ inline void SetParallelismPerKPU(int value) { m_parallelismPerKPUHasBeenSet = true; m_parallelismPerKPU = value; } /** *

Describes the number of parallel tasks that a Flink-based Kinesis Data * Analytics application can perform per Kinesis Processing Unit (KPU) used by the * application.

*/ inline ParallelismConfigurationDescription& WithParallelismPerKPU(int value) { SetParallelismPerKPU(value); return *this;} /** *

Describes the current number of parallel tasks that a Flink-based Kinesis * Data Analytics application can perform. If AutoScalingEnabled is * set to True, Kinesis Data Analytics can increase this value in response to * application load. The service can increase this value up to the maximum * parallelism, which is ParalellismPerKPU times the maximum KPUs for * the application. The maximum KPUs for an application is 32 by default, and can * be increased by requesting a limit increase. If application load is reduced, the * service can reduce the CurrentParallelism value down to the * Parallelism setting.

*/ inline int GetCurrentParallelism() const{ return m_currentParallelism; } /** *

Describes the current number of parallel tasks that a Flink-based Kinesis * Data Analytics application can perform. If AutoScalingEnabled is * set to True, Kinesis Data Analytics can increase this value in response to * application load. The service can increase this value up to the maximum * parallelism, which is ParalellismPerKPU times the maximum KPUs for * the application. The maximum KPUs for an application is 32 by default, and can * be increased by requesting a limit increase. If application load is reduced, the * service can reduce the CurrentParallelism value down to the * Parallelism setting.

*/ inline bool CurrentParallelismHasBeenSet() const { return m_currentParallelismHasBeenSet; } /** *

Describes the current number of parallel tasks that a Flink-based Kinesis * Data Analytics application can perform. If AutoScalingEnabled is * set to True, Kinesis Data Analytics can increase this value in response to * application load. The service can increase this value up to the maximum * parallelism, which is ParalellismPerKPU times the maximum KPUs for * the application. The maximum KPUs for an application is 32 by default, and can * be increased by requesting a limit increase. If application load is reduced, the * service can reduce the CurrentParallelism value down to the * Parallelism setting.

*/ inline void SetCurrentParallelism(int value) { m_currentParallelismHasBeenSet = true; m_currentParallelism = value; } /** *

Describes the current number of parallel tasks that a Flink-based Kinesis * Data Analytics application can perform. If AutoScalingEnabled is * set to True, Kinesis Data Analytics can increase this value in response to * application load. The service can increase this value up to the maximum * parallelism, which is ParalellismPerKPU times the maximum KPUs for * the application. The maximum KPUs for an application is 32 by default, and can * be increased by requesting a limit increase. If application load is reduced, the * service can reduce the CurrentParallelism value down to the * Parallelism setting.

*/ inline ParallelismConfigurationDescription& WithCurrentParallelism(int value) { SetCurrentParallelism(value); return *this;} /** *

Describes whether the Kinesis Data Analytics service can increase the * parallelism of the application in response to increased throughput.

*/ inline bool GetAutoScalingEnabled() const{ return m_autoScalingEnabled; } /** *

Describes whether the Kinesis Data Analytics service can increase the * parallelism of the application in response to increased throughput.

*/ inline bool AutoScalingEnabledHasBeenSet() const { return m_autoScalingEnabledHasBeenSet; } /** *

Describes whether the Kinesis Data Analytics service can increase the * parallelism of the application in response to increased throughput.

*/ inline void SetAutoScalingEnabled(bool value) { m_autoScalingEnabledHasBeenSet = true; m_autoScalingEnabled = value; } /** *

Describes whether the Kinesis Data Analytics service can increase the * parallelism of the application in response to increased throughput.

*/ inline ParallelismConfigurationDescription& WithAutoScalingEnabled(bool value) { SetAutoScalingEnabled(value); return *this;} private: ConfigurationType m_configurationType; bool m_configurationTypeHasBeenSet = false; int m_parallelism; bool m_parallelismHasBeenSet = false; int m_parallelismPerKPU; bool m_parallelismPerKPUHasBeenSet = false; int m_currentParallelism; bool m_currentParallelismHasBeenSet = false; bool m_autoScalingEnabled; bool m_autoScalingEnabledHasBeenSet = false; }; } // namespace Model } // namespace KinesisAnalyticsV2 } // namespace Aws