Class: AWSCDK::KinesisAnalyticsv2::CfnApplication::ParallelismConfigurationProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kinesis_analyticsv2/cfn_application.rb

Overview

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 .

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(configuration_type:, auto_scaling_enabled: nil, parallelism: nil, parallelism_per_kpu: nil) ⇒ ParallelismConfigurationProperty

Returns a new instance of ParallelismConfigurationProperty.

Parameters:

  • configuration_type (String) —

    Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.

  • auto_scaling_enabled (Boolean, AWSCDK::IResolvable, nil) (defaults to: nil) —

    Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.

  • parallelism (Numeric, nil) (defaults to: nil) —

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

  • parallelism_per_kpu (Numeric, nil) (defaults to: nil) —

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



1956
1957
1958
1959
1960
1961
1962
1963
1964
1965
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1956

def initialize(configuration_type:, auto_scaling_enabled: nil, parallelism: nil, parallelism_per_kpu: nil)
  @configuration_type = configuration_type
  Jsii::Type.check_type(@configuration_type, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "configurationType")
  @auto_scaling_enabled = auto_scaling_enabled
  Jsii::Type.check_type(@auto_scaling_enabled, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3sicHJpbWl0aXZlIjoiYm9vbGVhbiJ9LHsiZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifV19fQ==")), "autoScalingEnabled") unless @auto_scaling_enabled.nil?
  @parallelism = parallelism
  Jsii::Type.check_type(@parallelism, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "parallelism") unless @parallelism.nil?
  @parallelism_per_kpu = parallelism_per_kpu
  Jsii::Type.check_type(@parallelism_per_kpu, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "parallelismPerKpu") unless @parallelism_per_kpu.nil?
end

Instance Attribute Details

#auto_scaling_enabled ⇒ Boolean, ... (readonly)

Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.

Returns:

See Also:



1978
1979
1980
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1978

def auto_scaling_enabled
  @auto_scaling_enabled
end

#configuration_type ⇒ String (readonly)

Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.

You must set this property to CUSTOM in order to change your application's AutoScalingEnabled , Parallelism , or ParallelismPerKPU properties.

Returns:

  • (String)

See Also:



1973
1974
1975
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1973

def configuration_type
  @configuration_type
end

#parallelism ⇒ Numeric? (readonly)

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

The Kinesis Data Analytics service can increase this number automatically if ParallelismConfiguration:AutoScalingEnabled is set to true .

Returns:

  • (Numeric, nil)

See Also:



1985
1986
1987
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1985

def parallelism
  @parallelism
end

#parallelism_per_kpu ⇒ Numeric? (readonly)

Describes the number of parallel tasks that a Java-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 .

Returns:

  • (Numeric, nil)

See Also:



1992
1993
1994
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1992

def parallelism_per_kpu
  @parallelism_per_kpu
end

Class Method Details

.jsii_properties ⇒ Object 



1994
1995
1996
1997
1998
1999
2000
2001
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1994

def self.jsii_properties
  {
    :configuration_type => "configurationType",
    :auto_scaling_enabled => "autoScalingEnabled",
    :parallelism => "parallelism",
    :parallelism_per_kpu => "parallelismPerKpu",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



2003
2004
2005
2006
2007
2008
2009
2010
2011
2012
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 2003

def to_jsii
  result = {}
  result.merge!({
    "configurationType" => @configuration_type,
    "autoScalingEnabled" => @auto_scaling_enabled,
    "parallelism" => @parallelism,
    "parallelismPerKpu" => @parallelism_per_kpu,
  })
  result.compact
end