Class: AWSCDK::KinesisAnalytics::CfnApplicationV2::FlinkApplicationConfigurationProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kinesis_analytics/cfn_application_v2.rb

Overview

Describes configuration parameters for a Managed Service for Apache Flink application or a Studio notebook.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(checkpoint_configuration: nil, monitoring_configuration: nil, parallelism_configuration: nil) ⇒ FlinkApplicationConfigurationProperty

Returns a new instance of FlinkApplicationConfigurationProperty.

Parameters:



1324
1325
1326
1327
1328
1329
1330
1331
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1324

def initialize(checkpoint_configuration: nil, monitoring_configuration: nil, parallelism_configuration: nil)
  @checkpoint_configuration = checkpoint_configuration.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationV2::CheckpointConfigurationProperty.new(**checkpoint_configuration.transform_keys(&:to_sym)) : checkpoint_configuration
  Jsii::Type.check_type(@checkpoint_configuration, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uVjIuQ2hlY2twb2ludENvbmZpZ3VyYXRpb25Qcm9wZXJ0eSJ9XX19")), "checkpointConfiguration") unless @checkpoint_configuration.nil?
  @monitoring_configuration = monitoring_configuration.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationV2::MonitoringConfigurationProperty.new(**monitoring_configuration.transform_keys(&:to_sym)) : monitoring_configuration
  Jsii::Type.check_type(@monitoring_configuration, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uVjIuTW9uaXRvcmluZ0NvbmZpZ3VyYXRpb25Qcm9wZXJ0eSJ9XX19")), "monitoringConfiguration") unless @monitoring_configuration.nil?
  @parallelism_configuration = parallelism_configuration.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationV2::ParallelismConfigurationProperty.new(**parallelism_configuration.transform_keys(&:to_sym)) : parallelism_configuration
  Jsii::Type.check_type(@parallelism_configuration, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uVjIuUGFyYWxsZWxpc21Db25maWd1cmF0aW9uUHJvcGVydHkifV19fQ==")), "parallelismConfiguration") unless @parallelism_configuration.nil?
end

Instance Attribute Details

#checkpoint_configuration ⇒ AWSCDK::IResolvable, ... (readonly)

Describes an application's checkpointing configuration.

Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation .

Returns:

See Also:



1339
1340
1341
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1339

def checkpoint_configuration
  @checkpoint_configuration
end

#monitoring_configuration ⇒ AWSCDK::IResolvable, ... (readonly)

Describes configuration parameters for Amazon CloudWatch logging for an application.

Returns:

See Also:



1344
1345
1346
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1344

def monitoring_configuration
  @monitoring_configuration
end

#parallelism_configuration ⇒ AWSCDK::IResolvable, ... (readonly)

Describes parameters for how an application executes multiple tasks simultaneously.

Returns:

See Also:



1349
1350
1351
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1349

def parallelism_configuration
  @parallelism_configuration
end

Class Method Details

.jsii_properties ⇒ Object 



1351
1352
1353
1354
1355
1356
1357
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1351

def self.jsii_properties
  {
    :checkpoint_configuration => "checkpointConfiguration",
    :monitoring_configuration => "monitoringConfiguration",
    :parallelism_configuration => "parallelismConfiguration",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



1359
1360
1361
1362
1363
1364
1365
1366
1367
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1359

def to_jsii
  result = {}
  result.merge!({
    "checkpointConfiguration" => @checkpoint_configuration,
    "monitoringConfiguration" => @monitoring_configuration,
    "parallelismConfiguration" => @parallelism_configuration,
  })
  result.compact
end