Class: Aws::KinesisAnalyticsV2::Types::FlinkApplicationConfiguration

Inherits:
Struct
  • Object
show all
Includes:
Structure
Defined in:
lib/aws-sdk-kinesisanalyticsv2/types.rb

Overview

Note:

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

{
  checkpoint_configuration: {
    configuration_type: "DEFAULT", # required, accepts DEFAULT, CUSTOM
    checkpointing_enabled: false,
    checkpoint_interval: 1,
    min_pause_between_checkpoints: 1,
  },
  monitoring_configuration: {
    configuration_type: "DEFAULT", # required, accepts DEFAULT, CUSTOM
    metrics_level: "APPLICATION", # accepts APPLICATION, TASK, OPERATOR, PARALLELISM
    log_level: "INFO", # accepts INFO, WARN, ERROR, DEBUG
  },
  parallelism_configuration: {
    configuration_type: "DEFAULT", # required, accepts DEFAULT, CUSTOM
    parallelism: 1,
    parallelism_per_kpu: 1,
    auto_scaling_enabled: false,
  },
}

Describes configuration parameters for a Flink-based Kinesis Data Analytics application or a Studio notebook.

See Also:

Constant Summary collapse

SENSITIVE = 
[]

Instance Attribute Summary collapse

Instance Attribute Details

#checkpoint_configuration ⇒ Types::CheckpointConfiguration

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].

[1]: ci.apache.org/projects/flink/flink-docs-release-1.8/concepts/programming-model.html#checkpoints-for-fault-tolerance [2]: ci.apache.org/projects/flink/flink-docs-release-1.8/

Returns:



3201
3202
3203
3204
3205
3206
3207
 
# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 3201

class FlinkApplicationConfiguration < Struct.new(
  :checkpoint_configuration,
  :monitoring_configuration,
  :parallelism_configuration)
  SENSITIVE = []
  include Aws::Structure
end

#monitoring_configuration ⇒ Types::MonitoringConfiguration

Describes configuration parameters for Amazon CloudWatch logging for an application.

Returns:



3201
3202
3203
3204
3205
3206
3207
 
# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 3201

class FlinkApplicationConfiguration < Struct.new(
  :checkpoint_configuration,
  :monitoring_configuration,
  :parallelism_configuration)
  SENSITIVE = []
  include Aws::Structure
end

#parallelism_configuration ⇒ Types::ParallelismConfiguration

Describes parameters for how an application executes multiple tasks simultaneously.

Returns:



3201
3202
3203
3204
3205
3206
3207
 
# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 3201

class FlinkApplicationConfiguration < Struct.new(
  :checkpoint_configuration,
  :monitoring_configuration,
  :parallelism_configuration)
  SENSITIVE = []
  include Aws::Structure
end