Class: AWSCDK::KinesisAnalytics::CfnApplicationV2::ParallelismConfigurationProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kinesis_analytics/cfn_application_v2.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.



1957
1958
1959
1960
1961
1962
1963
1964
1965
1966
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1957

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:



1979
1980
1981
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1979

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:



1974
1975
1976
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1974

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:



1986
1987
1988
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1986

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:



1993
1994
1995
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1993

def parallelism_per_kpu
  @parallelism_per_kpu
end

Class Method Details

.jsii_properties ⇒ Object 



1995
1996
1997
1998
1999
2000
2001
2002
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1995

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

Instance Method Details

#to_jsii ⇒ Object 



2004
2005
2006
2007
2008
2009
2010
2011
2012
2013
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 2004

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