You are viewing documentation for version 2 of the AWS SDK for Ruby. Version 3 documentation can be found here.
Class: Aws::KinesisAnalyticsV2::Types::ApplicationConfiguration
- Inherits:
-
Struct
- Object
- Struct
- Aws::KinesisAnalyticsV2::Types::ApplicationConfiguration
- Defined in:
- (unknown)
Overview
When passing ApplicationConfiguration as input to an Aws::Client method, you can use a vanilla Hash:
{
sql_application_configuration: {
inputs: [
{
name_prefix: "InAppStreamName", # required
input_processing_configuration: {
input_lambda_processor: { # required
resource_arn: "ResourceARN", # required
},
},
kinesis_streams_input: {
resource_arn: "ResourceARN", # required
},
kinesis_firehose_input: {
resource_arn: "ResourceARN", # required
},
input_parallelism: {
count: 1,
},
input_schema: { # required
record_format: { # required
record_format_type: "JSON", # required, accepts JSON, CSV
mapping_parameters: {
json_mapping_parameters: {
record_row_path: "RecordRowPath", # required
},
csv_mapping_parameters: {
record_row_delimiter: "RecordRowDelimiter", # required
record_column_delimiter: "RecordColumnDelimiter", # required
},
},
},
record_encoding: "RecordEncoding",
record_columns: [ # required
{
name: "RecordColumnName", # required
mapping: "RecordColumnMapping",
sql_type: "RecordColumnSqlType", # required
},
],
},
},
],
outputs: [
{
name: "InAppStreamName", # required
kinesis_streams_output: {
resource_arn: "ResourceARN", # required
},
kinesis_firehose_output: {
resource_arn: "ResourceARN", # required
},
lambda_output: {
resource_arn: "ResourceARN", # required
},
destination_schema: { # required
record_format_type: "JSON", # required, accepts JSON, CSV
},
},
],
reference_data_sources: [
{
table_name: "InAppTableName", # required
s3_reference_data_source: {
bucket_arn: "BucketARN",
file_key: "FileKey",
},
reference_schema: { # required
record_format: { # required
record_format_type: "JSON", # required, accepts JSON, CSV
mapping_parameters: {
json_mapping_parameters: {
record_row_path: "RecordRowPath", # required
},
csv_mapping_parameters: {
record_row_delimiter: "RecordRowDelimiter", # required
record_column_delimiter: "RecordColumnDelimiter", # required
},
},
},
record_encoding: "RecordEncoding",
record_columns: [ # required
{
name: "RecordColumnName", # required
mapping: "RecordColumnMapping",
sql_type: "RecordColumnSqlType", # required
},
],
},
},
],
},
flink_application_configuration: {
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,
},
},
environment_properties: {
property_groups: [ # required
{
property_group_id: "Id", # required
property_map: { # required
"PropertyKey" => "PropertyValue",
},
},
],
},
application_code_configuration: { # required
code_content: {
text_content: "TextContent",
zip_file_content: "data",
s3_content_location: {
bucket_arn: "BucketARN", # required
file_key: "FileKey", # required
object_version: "ObjectVersion",
},
},
code_content_type: "PLAINTEXT", # required, accepts PLAINTEXT, ZIPFILE
},
application_snapshot_configuration: {
snapshots_enabled: false, # required
},
vpc_configurations: [
{
subnet_ids: ["SubnetId"], # required
security_group_ids: ["SecurityGroupId"], # required
},
],
}
Specifies the creation parameters for a Kinesis Data Analytics application.
Returned by:
Instance Attribute Summary collapse
-
#application_code_configuration ⇒ Types::ApplicationCodeConfiguration
The code location and type parameters for a Flink-based Kinesis Data Analytics application.
-
#application_snapshot_configuration ⇒ Types::ApplicationSnapshotConfiguration
Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
-
#environment_properties ⇒ Types::EnvironmentProperties
Describes execution properties for a Flink-based Kinesis Data Analytics application.
-
#flink_application_configuration ⇒ Types::FlinkApplicationConfiguration
The creation and update parameters for a Flink-based Kinesis Data Analytics application.
-
#sql_application_configuration ⇒ Types::SqlApplicationConfiguration
The creation and update parameters for a SQL-based Kinesis Data Analytics application.
-
#vpc_configurations ⇒ Array<Types::VpcConfiguration>
The array of descriptions of VPC configurations available to the application.
Instance Attribute Details
#application_code_configuration ⇒ Types::ApplicationCodeConfiguration
The code location and type parameters for a Flink-based Kinesis Data Analytics application.
#application_snapshot_configuration ⇒ Types::ApplicationSnapshotConfiguration
Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
#environment_properties ⇒ Types::EnvironmentProperties
Describes execution properties for a Flink-based Kinesis Data Analytics application.
#flink_application_configuration ⇒ Types::FlinkApplicationConfiguration
The creation and update parameters for a Flink-based Kinesis Data Analytics application.
#sql_application_configuration ⇒ Types::SqlApplicationConfiguration
The creation and update parameters for a SQL-based Kinesis Data Analytics application.
#vpc_configurations ⇒ Array<Types::VpcConfiguration>
The array of descriptions of VPC configurations available to the application.