Class: AWSCDK::KinesisAnalyticsv2::CfnApplication::FlinkApplicationConfigurationProperty

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



1323
1324
1325
1326
1327
1328
1329
1330
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1323

def initialize(checkpoint_configuration: nil, monitoring_configuration: nil, parallelism_configuration: nil)
  @checkpoint_configuration = checkpoint_configuration.is_a?(Hash) ? ::AWSCDK::KinesisAnalyticsv2::CfnApplication::CheckpointConfigurationProperty.new(**checkpoint_configuration.transform_keys(&:to_sym)) : checkpoint_configuration
  Jsii::Type.check_type(@checkpoint_configuration, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzdjIuQ2ZuQXBwbGljYXRpb24uQ2hlY2twb2ludENvbmZpZ3VyYXRpb25Qcm9wZXJ0eSJ9XX19")), "checkpointConfiguration") unless @checkpoint_configuration.nil?
  @monitoring_configuration = monitoring_configuration.is_a?(Hash) ? ::AWSCDK::KinesisAnalyticsv2::CfnApplication::MonitoringConfigurationProperty.new(**monitoring_configuration.transform_keys(&:to_sym)) : monitoring_configuration
  Jsii::Type.check_type(@monitoring_configuration, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzdjIuQ2ZuQXBwbGljYXRpb24uTW9uaXRvcmluZ0NvbmZpZ3VyYXRpb25Qcm9wZXJ0eSJ9XX19")), "monitoringConfiguration") unless @monitoring_configuration.nil?
  @parallelism_configuration = parallelism_configuration.is_a?(Hash) ? ::AWSCDK::KinesisAnalyticsv2::CfnApplication::ParallelismConfigurationProperty.new(**parallelism_configuration.transform_keys(&:to_sym)) : parallelism_configuration
  Jsii::Type.check_type(@parallelism_configuration, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzdjIuQ2ZuQXBwbGljYXRpb24uUGFyYWxsZWxpc21Db25maWd1cmF0aW9uUHJvcGVydHkifV19fQ==")), "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:



1338
1339
1340
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1338

def checkpoint_configuration
  @checkpoint_configuration
end

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

Describes configuration parameters for Amazon CloudWatch logging for an application.

Returns:

See Also:



1343
1344
1345
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1343

def monitoring_configuration
  @monitoring_configuration
end

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

Describes parameters for how an application executes multiple tasks simultaneously.

Returns:

See Also:



1348
1349
1350
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1348

def parallelism_configuration
  @parallelism_configuration
end

Class Method Details

.jsii_properties ⇒ Object 



1350
1351
1352
1353
1354
1355
1356
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1350

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

Instance Method Details

#to_jsii ⇒ Object 



1358
1359
1360
1361
1362
1363
1364
1365
1366
 
# File 'kinesis_analyticsv2/cfn_application.rb', line 1358

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