/**
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
* SPDX-License-Identifier: Apache-2.0.
*/
#pragma once
#include Describes parameters for how a Flink-based Kinesis Data Analytics application
* executes multiple tasks simultaneously.See Also:
AWS
* API Reference
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.
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.
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.
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.
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.
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.
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.
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.
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