Class: Aws::KinesisAnalyticsV2::Types::ParallelismConfiguration

Inherits:

Struct

• Object
• Struct
• Aws::KinesisAnalyticsV2::Types::ParallelismConfiguration

Includes:

Structure

Defined in:

lib/aws-sdk-kinesisanalyticsv2/types.rb

Overview

Note:

When making an API call, you may pass ParallelismConfiguration data as a hash:

{
  configuration_type: "DEFAULT", # required, accepts DEFAULT, CUSTOM
  parallelism: 1,
  parallelism_per_kpu: 1,
  auto_scaling_enabled: false,
}

Describes parameters for how a Flink-based Kinesis Data Analytics application executes multiple tasks simultaneously. For more information about parallelism, see [Parallel Execution] in the [Apache Flink Documentation].

[1]: ci.apache.org/projects/flink/flink-docs-release-1.8/dev/parallel.html [2]: ci.apache.org/projects/flink/flink-docs-release-1.8/

See Also:

• AWS API Documentation

Constant Summary

SENSITIVE =

[]

Instance Attribute Summary

• #auto_scaling_enabled ⇒ Boolean

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

• #configuration_type ⇒ String

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

• #parallelism ⇒ Integer

  Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.

• #parallelism_per_kpu ⇒ Integer

  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.

Instance Attribute Details

#auto_scaling_enabled ⇒ Boolean

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

Returns:

• (Boolean)

# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 5085

class ParallelismConfiguration < Struct.new(
  :configuration_type,
  :parallelism,
  :parallelism_per_kpu,
  :auto_scaling_enabled)
  SENSITIVE = []
  include Aws::Structure
end

#configuration_type ⇒ String

Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. You must set this property to `CUSTOM` in order to change your application's `AutoScalingEnabled`, `Parallelism`, or `ParallelismPerKPU` properties.

Returns:

• (String)

# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 5085

class ParallelismConfiguration < Struct.new(
  :configuration_type,
  :parallelism,
  :parallelism_per_kpu,
  :auto_scaling_enabled)
  SENSITIVE = []
  include Aws::Structure
end

#parallelism ⇒ Integer

Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform. If `AutoScalingEnabled` is set to True, Kinesis Data Analytics increases the `CurrentParallelism` value in response to application load. The service can increase the `CurrentParallelism` 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.

Returns:

• (Integer)

# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 5085

class ParallelismConfiguration < Struct.new(
  :configuration_type,
  :parallelism,
  :parallelism_per_kpu,
  :auto_scaling_enabled)
  SENSITIVE = []
  include Aws::Structure
end

#parallelism_per_kpu ⇒ Integer

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. For more information about KPUs, see [Amazon Kinesis Data Analytics Pricing].

[1]: aws.amazon.com/kinesis/data-analytics/pricing/

Returns:

• (Integer)

# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 5085

class ParallelismConfiguration < Struct.new(
  :configuration_type,
  :parallelism,
  :parallelism_per_kpu,
  :auto_scaling_enabled)
  SENSITIVE = []
  include Aws::Structure
end