1. Packages
  2. AWS Classic
  3. API Docs
  4. kinesisanalyticsv2
  5. Application

Try AWS Native preview for resources not in the classic version.

AWS Classic v6.40.0 published on Wednesday, Jun 12, 2024 by Pulumi

aws.kinesisanalyticsv2.Application

Explore with Pulumi AI

aws logo

Try AWS Native preview for resources not in the classic version.

AWS Classic v6.40.0 published on Wednesday, Jun 12, 2024 by Pulumi

    Manages a Kinesis Analytics v2 Application. This resource can be used to manage both Kinesis Data Analytics for SQL applications and Kinesis Data Analytics for Apache Flink applications.

    Note: Kinesis Data Analytics for SQL applications created using this resource cannot currently be viewed in the AWS Console. To manage Kinesis Data Analytics for SQL applications that can also be viewed in the AWS Console, use the aws.kinesis.AnalyticsApplication resource.

    Example Usage

    import * as pulumi from "@pulumi/pulumi";
    import * as aws from "@pulumi/aws";
    
    const example = new aws.s3.BucketV2("example", {bucket: "example-flink-application"});
    const exampleBucketObjectv2 = new aws.s3.BucketObjectv2("example", {
        bucket: example.id,
        key: "example-flink-application",
        source: new pulumi.asset.FileAsset("flink-app.jar"),
    });
    const exampleApplication = new aws.kinesisanalyticsv2.Application("example", {
        name: "example-flink-application",
        runtimeEnvironment: "FLINK-1_8",
        serviceExecutionRole: exampleAwsIamRole.arn,
        applicationConfiguration: {
            applicationCodeConfiguration: {
                codeContent: {
                    s3ContentLocation: {
                        bucketArn: example.arn,
                        fileKey: exampleBucketObjectv2.key,
                    },
                },
                codeContentType: "ZIPFILE",
            },
            environmentProperties: {
                propertyGroups: [
                    {
                        propertyGroupId: "PROPERTY-GROUP-1",
                        propertyMap: {
                            Key1: "Value1",
                        },
                    },
                    {
                        propertyGroupId: "PROPERTY-GROUP-2",
                        propertyMap: {
                            KeyA: "ValueA",
                            KeyB: "ValueB",
                        },
                    },
                ],
            },
            flinkApplicationConfiguration: {
                checkpointConfiguration: {
                    configurationType: "DEFAULT",
                },
                monitoringConfiguration: {
                    configurationType: "CUSTOM",
                    logLevel: "DEBUG",
                    metricsLevel: "TASK",
                },
                parallelismConfiguration: {
                    autoScalingEnabled: true,
                    configurationType: "CUSTOM",
                    parallelism: 10,
                    parallelismPerKpu: 4,
                },
            },
        },
        tags: {
            Environment: "test",
        },
    });
    
    import pulumi
    import pulumi_aws as aws
    
    example = aws.s3.BucketV2("example", bucket="example-flink-application")
    example_bucket_objectv2 = aws.s3.BucketObjectv2("example",
        bucket=example.id,
        key="example-flink-application",
        source=pulumi.FileAsset("flink-app.jar"))
    example_application = aws.kinesisanalyticsv2.Application("example",
        name="example-flink-application",
        runtime_environment="FLINK-1_8",
        service_execution_role=example_aws_iam_role["arn"],
        application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationArgs(
            application_code_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs(
                code_content=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs(
                    s3_content_location=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs(
                        bucket_arn=example.arn,
                        file_key=example_bucket_objectv2.key,
                    ),
                ),
                code_content_type="ZIPFILE",
            ),
            environment_properties=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesArgs(
                property_groups=[
                    aws.kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs(
                        property_group_id="PROPERTY-GROUP-1",
                        property_map={
                            "Key1": "Value1",
                        },
                    ),
                    aws.kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs(
                        property_group_id="PROPERTY-GROUP-2",
                        property_map={
                            "KeyA": "ValueA",
                            "KeyB": "ValueB",
                        },
                    ),
                ],
            ),
            flink_application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs(
                checkpoint_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs(
                    configuration_type="DEFAULT",
                ),
                monitoring_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs(
                    configuration_type="CUSTOM",
                    log_level="DEBUG",
                    metrics_level="TASK",
                ),
                parallelism_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs(
                    auto_scaling_enabled=True,
                    configuration_type="CUSTOM",
                    parallelism=10,
                    parallelism_per_kpu=4,
                ),
            ),
        ),
        tags={
            "Environment": "test",
        })
    
    package main
    
    import (
    	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/kinesisanalyticsv2"
    	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/s3"
    	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
    )
    
    func main() {
    	pulumi.Run(func(ctx *pulumi.Context) error {
    		example, err := s3.NewBucketV2(ctx, "example", &s3.BucketV2Args{
    			Bucket: pulumi.String("example-flink-application"),
    		})
    		if err != nil {
    			return err
    		}
    		exampleBucketObjectv2, err := s3.NewBucketObjectv2(ctx, "example", &s3.BucketObjectv2Args{
    			Bucket: example.ID(),
    			Key:    pulumi.String("example-flink-application"),
    			Source: pulumi.NewFileAsset("flink-app.jar"),
    		})
    		if err != nil {
    			return err
    		}
    		_, err = kinesisanalyticsv2.NewApplication(ctx, "example", &kinesisanalyticsv2.ApplicationArgs{
    			Name:                 pulumi.String("example-flink-application"),
    			RuntimeEnvironment:   pulumi.String("FLINK-1_8"),
    			ServiceExecutionRole: pulumi.Any(exampleAwsIamRole.Arn),
    			ApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationArgs{
    				ApplicationCodeConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs{
    					CodeContent: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs{
    						S3ContentLocation: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs{
    							BucketArn: example.Arn,
    							FileKey:   exampleBucketObjectv2.Key,
    						},
    					},
    					CodeContentType: pulumi.String("ZIPFILE"),
    				},
    				EnvironmentProperties: &kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesArgs{
    					PropertyGroups: kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArray{
    						&kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs{
    							PropertyGroupId: pulumi.String("PROPERTY-GROUP-1"),
    							PropertyMap: pulumi.StringMap{
    								"Key1": pulumi.String("Value1"),
    							},
    						},
    						&kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs{
    							PropertyGroupId: pulumi.String("PROPERTY-GROUP-2"),
    							PropertyMap: pulumi.StringMap{
    								"KeyA": pulumi.String("ValueA"),
    								"KeyB": pulumi.String("ValueB"),
    							},
    						},
    					},
    				},
    				FlinkApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs{
    					CheckpointConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs{
    						ConfigurationType: pulumi.String("DEFAULT"),
    					},
    					MonitoringConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs{
    						ConfigurationType: pulumi.String("CUSTOM"),
    						LogLevel:          pulumi.String("DEBUG"),
    						MetricsLevel:      pulumi.String("TASK"),
    					},
    					ParallelismConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs{
    						AutoScalingEnabled: pulumi.Bool(true),
    						ConfigurationType:  pulumi.String("CUSTOM"),
    						Parallelism:        pulumi.Int(10),
    						ParallelismPerKpu:  pulumi.Int(4),
    					},
    				},
    			},
    			Tags: pulumi.StringMap{
    				"Environment": pulumi.String("test"),
    			},
    		})
    		if err != nil {
    			return err
    		}
    		return nil
    	})
    }
    
    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using Aws = Pulumi.Aws;
    
    return await Deployment.RunAsync(() => 
    {
        var example = new Aws.S3.BucketV2("example", new()
        {
            Bucket = "example-flink-application",
        });
    
        var exampleBucketObjectv2 = new Aws.S3.BucketObjectv2("example", new()
        {
            Bucket = example.Id,
            Key = "example-flink-application",
            Source = new FileAsset("flink-app.jar"),
        });
    
        var exampleApplication = new Aws.KinesisAnalyticsV2.Application("example", new()
        {
            Name = "example-flink-application",
            RuntimeEnvironment = "FLINK-1_8",
            ServiceExecutionRole = exampleAwsIamRole.Arn,
            ApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationArgs
            {
                ApplicationCodeConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs
                {
                    CodeContent = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs
                    {
                        S3ContentLocation = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs
                        {
                            BucketArn = example.Arn,
                            FileKey = exampleBucketObjectv2.Key,
                        },
                    },
                    CodeContentType = "ZIPFILE",
                },
                EnvironmentProperties = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationEnvironmentPropertiesArgs
                {
                    PropertyGroups = new[]
                    {
                        new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs
                        {
                            PropertyGroupId = "PROPERTY-GROUP-1",
                            PropertyMap = 
                            {
                                { "Key1", "Value1" },
                            },
                        },
                        new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs
                        {
                            PropertyGroupId = "PROPERTY-GROUP-2",
                            PropertyMap = 
                            {
                                { "KeyA", "ValueA" },
                                { "KeyB", "ValueB" },
                            },
                        },
                    },
                },
                FlinkApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs
                {
                    CheckpointConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs
                    {
                        ConfigurationType = "DEFAULT",
                    },
                    MonitoringConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs
                    {
                        ConfigurationType = "CUSTOM",
                        LogLevel = "DEBUG",
                        MetricsLevel = "TASK",
                    },
                    ParallelismConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs
                    {
                        AutoScalingEnabled = true,
                        ConfigurationType = "CUSTOM",
                        Parallelism = 10,
                        ParallelismPerKpu = 4,
                    },
                },
            },
            Tags = 
            {
                { "Environment", "test" },
            },
        });
    
    });
    
    package generated_program;
    
    import com.pulumi.Context;
    import com.pulumi.Pulumi;
    import com.pulumi.core.Output;
    import com.pulumi.aws.s3.BucketV2;
    import com.pulumi.aws.s3.BucketV2Args;
    import com.pulumi.aws.s3.BucketObjectv2;
    import com.pulumi.aws.s3.BucketObjectv2Args;
    import com.pulumi.aws.kinesisanalyticsv2.Application;
    import com.pulumi.aws.kinesisanalyticsv2.ApplicationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationEnvironmentPropertiesArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs;
    import com.pulumi.asset.FileAsset;
    import java.util.List;
    import java.util.ArrayList;
    import java.util.Map;
    import java.io.File;
    import java.nio.file.Files;
    import java.nio.file.Paths;
    
    public class App {
        public static void main(String[] args) {
            Pulumi.run(App::stack);
        }
    
        public static void stack(Context ctx) {
            var example = new BucketV2("example", BucketV2Args.builder()
                .bucket("example-flink-application")
                .build());
    
            var exampleBucketObjectv2 = new BucketObjectv2("exampleBucketObjectv2", BucketObjectv2Args.builder()
                .bucket(example.id())
                .key("example-flink-application")
                .source(new FileAsset("flink-app.jar"))
                .build());
    
            var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()
                .name("example-flink-application")
                .runtimeEnvironment("FLINK-1_8")
                .serviceExecutionRole(exampleAwsIamRole.arn())
                .applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
                    .applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
                        .codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
                            .s3ContentLocation(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs.builder()
                                .bucketArn(example.arn())
                                .fileKey(exampleBucketObjectv2.key())
                                .build())
                            .build())
                        .codeContentType("ZIPFILE")
                        .build())
                    .environmentProperties(ApplicationApplicationConfigurationEnvironmentPropertiesArgs.builder()
                        .propertyGroups(                    
                            ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs.builder()
                                .propertyGroupId("PROPERTY-GROUP-1")
                                .propertyMap(Map.of("Key1", "Value1"))
                                .build(),
                            ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs.builder()
                                .propertyGroupId("PROPERTY-GROUP-2")
                                .propertyMap(Map.ofEntries(
                                    Map.entry("KeyA", "ValueA"),
                                    Map.entry("KeyB", "ValueB")
                                ))
                                .build())
                        .build())
                    .flinkApplicationConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs.builder()
                        .checkpointConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs.builder()
                            .configurationType("DEFAULT")
                            .build())
                        .monitoringConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs.builder()
                            .configurationType("CUSTOM")
                            .logLevel("DEBUG")
                            .metricsLevel("TASK")
                            .build())
                        .parallelismConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.builder()
                            .autoScalingEnabled(true)
                            .configurationType("CUSTOM")
                            .parallelism(10)
                            .parallelismPerKpu(4)
                            .build())
                        .build())
                    .build())
                .tags(Map.of("Environment", "test"))
                .build());
    
        }
    }
    
    resources:
      example:
        type: aws:s3:BucketV2
        properties:
          bucket: example-flink-application
      exampleBucketObjectv2:
        type: aws:s3:BucketObjectv2
        name: example
        properties:
          bucket: ${example.id}
          key: example-flink-application
          source:
            fn::FileAsset: flink-app.jar
      exampleApplication:
        type: aws:kinesisanalyticsv2:Application
        name: example
        properties:
          name: example-flink-application
          runtimeEnvironment: FLINK-1_8
          serviceExecutionRole: ${exampleAwsIamRole.arn}
          applicationConfiguration:
            applicationCodeConfiguration:
              codeContent:
                s3ContentLocation:
                  bucketArn: ${example.arn}
                  fileKey: ${exampleBucketObjectv2.key}
              codeContentType: ZIPFILE
            environmentProperties:
              propertyGroups:
                - propertyGroupId: PROPERTY-GROUP-1
                  propertyMap:
                    Key1: Value1
                - propertyGroupId: PROPERTY-GROUP-2
                  propertyMap:
                    KeyA: ValueA
                    KeyB: ValueB
            flinkApplicationConfiguration:
              checkpointConfiguration:
                configurationType: DEFAULT
              monitoringConfiguration:
                configurationType: CUSTOM
                logLevel: DEBUG
                metricsLevel: TASK
              parallelismConfiguration:
                autoScalingEnabled: true
                configurationType: CUSTOM
                parallelism: 10
                parallelismPerKpu: 4
          tags:
            Environment: test
    

    SQL Application

    import * as pulumi from "@pulumi/pulumi";
    import * as aws from "@pulumi/aws";
    
    const example = new aws.cloudwatch.LogGroup("example", {name: "example-sql-application"});
    const exampleLogStream = new aws.cloudwatch.LogStream("example", {
        name: "example-sql-application",
        logGroupName: example.name,
    });
    const exampleApplication = new aws.kinesisanalyticsv2.Application("example", {
        name: "example-sql-application",
        runtimeEnvironment: "SQL-1_0",
        serviceExecutionRole: exampleAwsIamRole.arn,
        applicationConfiguration: {
            applicationCodeConfiguration: {
                codeContent: {
                    textContent: "SELECT 1;\n",
                },
                codeContentType: "PLAINTEXT",
            },
            sqlApplicationConfiguration: {
                input: {
                    namePrefix: "PREFIX_1",
                    inputParallelism: {
                        count: 3,
                    },
                    inputSchema: {
                        recordColumns: [
                            {
                                name: "COLUMN_1",
                                sqlType: "VARCHAR(8)",
                                mapping: "MAPPING-1",
                            },
                            {
                                name: "COLUMN_2",
                                sqlType: "DOUBLE",
                            },
                        ],
                        recordEncoding: "UTF-8",
                        recordFormat: {
                            recordFormatType: "CSV",
                            mappingParameters: {
                                csvMappingParameters: {
                                    recordColumnDelimiter: ",",
                                    recordRowDelimiter: "\n",
                                },
                            },
                        },
                    },
                    kinesisStreamsInput: {
                        resourceArn: exampleAwsKinesisStream.arn,
                    },
                },
                outputs: [
                    {
                        name: "OUTPUT_1",
                        destinationSchema: {
                            recordFormatType: "JSON",
                        },
                        lambdaOutput: {
                            resourceArn: exampleAwsLambdaFunction.arn,
                        },
                    },
                    {
                        name: "OUTPUT_2",
                        destinationSchema: {
                            recordFormatType: "CSV",
                        },
                        kinesisFirehoseOutput: {
                            resourceArn: exampleAwsKinesisFirehoseDeliveryStream.arn,
                        },
                    },
                ],
                referenceDataSource: {
                    tableName: "TABLE-1",
                    referenceSchema: {
                        recordColumns: [{
                            name: "COLUMN_1",
                            sqlType: "INTEGER",
                        }],
                        recordFormat: {
                            recordFormatType: "JSON",
                            mappingParameters: {
                                jsonMappingParameters: {
                                    recordRowPath: "$",
                                },
                            },
                        },
                    },
                    s3ReferenceDataSource: {
                        bucketArn: exampleAwsS3Bucket.arn,
                        fileKey: "KEY-1",
                    },
                },
            },
        },
        cloudwatchLoggingOptions: {
            logStreamArn: exampleLogStream.arn,
        },
    });
    
    import pulumi
    import pulumi_aws as aws
    
    example = aws.cloudwatch.LogGroup("example", name="example-sql-application")
    example_log_stream = aws.cloudwatch.LogStream("example",
        name="example-sql-application",
        log_group_name=example.name)
    example_application = aws.kinesisanalyticsv2.Application("example",
        name="example-sql-application",
        runtime_environment="SQL-1_0",
        service_execution_role=example_aws_iam_role["arn"],
        application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationArgs(
            application_code_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs(
                code_content=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs(
                    text_content="SELECT 1;\n",
                ),
                code_content_type="PLAINTEXT",
            ),
            sql_application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs(
                input=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs(
                    name_prefix="PREFIX_1",
                    input_parallelism=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs(
                        count=3,
                    ),
                    input_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs(
                        record_columns=[
                            aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs(
                                name="COLUMN_1",
                                sql_type="VARCHAR(8)",
                                mapping="MAPPING-1",
                            ),
                            aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs(
                                name="COLUMN_2",
                                sql_type="DOUBLE",
                            ),
                        ],
                        record_encoding="UTF-8",
                        record_format=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs(
                            record_format_type="CSV",
                            mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs(
                                csv_mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs(
                                    record_column_delimiter=",",
                                    record_row_delimiter="\n",
                                ),
                            ),
                        ),
                    ),
                    kinesis_streams_input=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs(
                        resource_arn=example_aws_kinesis_stream["arn"],
                    ),
                ),
                outputs=[
                    aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs(
                        name="OUTPUT_1",
                        destination_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs(
                            record_format_type="JSON",
                        ),
                        lambda_output=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs(
                            resource_arn=example_aws_lambda_function["arn"],
                        ),
                    ),
                    aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs(
                        name="OUTPUT_2",
                        destination_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs(
                            record_format_type="CSV",
                        ),
                        kinesis_firehose_output=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs(
                            resource_arn=example_aws_kinesis_firehose_delivery_stream["arn"],
                        ),
                    ),
                ],
                reference_data_source=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs(
                    table_name="TABLE-1",
                    reference_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs(
                        record_columns=[aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs(
                            name="COLUMN_1",
                            sql_type="INTEGER",
                        )],
                        record_format=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs(
                            record_format_type="JSON",
                            mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs(
                                json_mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs(
                                    record_row_path="$",
                                ),
                            ),
                        ),
                    ),
                    s3_reference_data_source=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs(
                        bucket_arn=example_aws_s3_bucket["arn"],
                        file_key="KEY-1",
                    ),
                ),
            ),
        ),
        cloudwatch_logging_options=aws.kinesisanalyticsv2.ApplicationCloudwatchLoggingOptionsArgs(
            log_stream_arn=example_log_stream.arn,
        ))
    
    package main
    
    import (
    	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/cloudwatch"
    	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/kinesisanalyticsv2"
    	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
    )
    
    func main() {
    	pulumi.Run(func(ctx *pulumi.Context) error {
    		example, err := cloudwatch.NewLogGroup(ctx, "example", &cloudwatch.LogGroupArgs{
    			Name: pulumi.String("example-sql-application"),
    		})
    		if err != nil {
    			return err
    		}
    		exampleLogStream, err := cloudwatch.NewLogStream(ctx, "example", &cloudwatch.LogStreamArgs{
    			Name:         pulumi.String("example-sql-application"),
    			LogGroupName: example.Name,
    		})
    		if err != nil {
    			return err
    		}
    		_, err = kinesisanalyticsv2.NewApplication(ctx, "example", &kinesisanalyticsv2.ApplicationArgs{
    			Name:                 pulumi.String("example-sql-application"),
    			RuntimeEnvironment:   pulumi.String("SQL-1_0"),
    			ServiceExecutionRole: pulumi.Any(exampleAwsIamRole.Arn),
    			ApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationArgs{
    				ApplicationCodeConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs{
    					CodeContent: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs{
    						TextContent: pulumi.String("SELECT 1;\n"),
    					},
    					CodeContentType: pulumi.String("PLAINTEXT"),
    				},
    				SqlApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs{
    					Input: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputTypeArgs{
    						NamePrefix: pulumi.String("PREFIX_1"),
    						InputParallelism: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs{
    							Count: pulumi.Int(3),
    						},
    						InputSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs{
    							RecordColumns: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArray{
    								&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs{
    									Name:    pulumi.String("COLUMN_1"),
    									SqlType: pulumi.String("VARCHAR(8)"),
    									Mapping: pulumi.String("MAPPING-1"),
    								},
    								&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs{
    									Name:    pulumi.String("COLUMN_2"),
    									SqlType: pulumi.String("DOUBLE"),
    								},
    							},
    							RecordEncoding: pulumi.String("UTF-8"),
    							RecordFormat: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs{
    								RecordFormatType: pulumi.String("CSV"),
    								MappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs{
    									CsvMappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs{
    										RecordColumnDelimiter: pulumi.String(","),
    										RecordRowDelimiter:    pulumi.String("\n"),
    									},
    								},
    							},
    						},
    						KinesisStreamsInput: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs{
    							ResourceArn: pulumi.Any(exampleAwsKinesisStream.Arn),
    						},
    					},
    					Outputs: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArray{
    						&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArgs{
    							Name: pulumi.String("OUTPUT_1"),
    							DestinationSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs{
    								RecordFormatType: pulumi.String("JSON"),
    							},
    							LambdaOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs{
    								ResourceArn: pulumi.Any(exampleAwsLambdaFunction.Arn),
    							},
    						},
    						&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArgs{
    							Name: pulumi.String("OUTPUT_2"),
    							DestinationSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs{
    								RecordFormatType: pulumi.String("CSV"),
    							},
    							KinesisFirehoseOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs{
    								ResourceArn: pulumi.Any(exampleAwsKinesisFirehoseDeliveryStream.Arn),
    							},
    						},
    					},
    					ReferenceDataSource: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs{
    						TableName: pulumi.String("TABLE-1"),
    						ReferenceSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs{
    							RecordColumns: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArray{
    								&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs{
    									Name:    pulumi.String("COLUMN_1"),
    									SqlType: pulumi.String("INTEGER"),
    								},
    							},
    							RecordFormat: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs{
    								RecordFormatType: pulumi.String("JSON"),
    								MappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs{
    									JsonMappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs{
    										RecordRowPath: pulumi.String("$"),
    									},
    								},
    							},
    						},
    						S3ReferenceDataSource: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs{
    							BucketArn: pulumi.Any(exampleAwsS3Bucket.Arn),
    							FileKey:   pulumi.String("KEY-1"),
    						},
    					},
    				},
    			},
    			CloudwatchLoggingOptions: &kinesisanalyticsv2.ApplicationCloudwatchLoggingOptionsArgs{
    				LogStreamArn: exampleLogStream.Arn,
    			},
    		})
    		if err != nil {
    			return err
    		}
    		return nil
    	})
    }
    
    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using Aws = Pulumi.Aws;
    
    return await Deployment.RunAsync(() => 
    {
        var example = new Aws.CloudWatch.LogGroup("example", new()
        {
            Name = "example-sql-application",
        });
    
        var exampleLogStream = new Aws.CloudWatch.LogStream("example", new()
        {
            Name = "example-sql-application",
            LogGroupName = example.Name,
        });
    
        var exampleApplication = new Aws.KinesisAnalyticsV2.Application("example", new()
        {
            Name = "example-sql-application",
            RuntimeEnvironment = "SQL-1_0",
            ServiceExecutionRole = exampleAwsIamRole.Arn,
            ApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationArgs
            {
                ApplicationCodeConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs
                {
                    CodeContent = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs
                    {
                        TextContent = @"SELECT 1;
    ",
                    },
                    CodeContentType = "PLAINTEXT",
                },
                SqlApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs
                {
                    Input = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs
                    {
                        NamePrefix = "PREFIX_1",
                        InputParallelism = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs
                        {
                            Count = 3,
                        },
                        InputSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs
                        {
                            RecordColumns = new[]
                            {
                                new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs
                                {
                                    Name = "COLUMN_1",
                                    SqlType = "VARCHAR(8)",
                                    Mapping = "MAPPING-1",
                                },
                                new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs
                                {
                                    Name = "COLUMN_2",
                                    SqlType = "DOUBLE",
                                },
                            },
                            RecordEncoding = "UTF-8",
                            RecordFormat = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs
                            {
                                RecordFormatType = "CSV",
                                MappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs
                                {
                                    CsvMappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs
                                    {
                                        RecordColumnDelimiter = ",",
                                        RecordRowDelimiter = @"
    ",
                                    },
                                },
                            },
                        },
                        KinesisStreamsInput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs
                        {
                            ResourceArn = exampleAwsKinesisStream.Arn,
                        },
                    },
                    Outputs = new[]
                    {
                        new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs
                        {
                            Name = "OUTPUT_1",
                            DestinationSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs
                            {
                                RecordFormatType = "JSON",
                            },
                            LambdaOutput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs
                            {
                                ResourceArn = exampleAwsLambdaFunction.Arn,
                            },
                        },
                        new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs
                        {
                            Name = "OUTPUT_2",
                            DestinationSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs
                            {
                                RecordFormatType = "CSV",
                            },
                            KinesisFirehoseOutput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs
                            {
                                ResourceArn = exampleAwsKinesisFirehoseDeliveryStream.Arn,
                            },
                        },
                    },
                    ReferenceDataSource = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs
                    {
                        TableName = "TABLE-1",
                        ReferenceSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs
                        {
                            RecordColumns = new[]
                            {
                                new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs
                                {
                                    Name = "COLUMN_1",
                                    SqlType = "INTEGER",
                                },
                            },
                            RecordFormat = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs
                            {
                                RecordFormatType = "JSON",
                                MappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs
                                {
                                    JsonMappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs
                                    {
                                        RecordRowPath = "$",
                                    },
                                },
                            },
                        },
                        S3ReferenceDataSource = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs
                        {
                            BucketArn = exampleAwsS3Bucket.Arn,
                            FileKey = "KEY-1",
                        },
                    },
                },
            },
            CloudwatchLoggingOptions = new Aws.KinesisAnalyticsV2.Inputs.ApplicationCloudwatchLoggingOptionsArgs
            {
                LogStreamArn = exampleLogStream.Arn,
            },
        });
    
    });
    
    package generated_program;
    
    import com.pulumi.Context;
    import com.pulumi.Pulumi;
    import com.pulumi.core.Output;
    import com.pulumi.aws.cloudwatch.LogGroup;
    import com.pulumi.aws.cloudwatch.LogGroupArgs;
    import com.pulumi.aws.cloudwatch.LogStream;
    import com.pulumi.aws.cloudwatch.LogStreamArgs;
    import com.pulumi.aws.kinesisanalyticsv2.Application;
    import com.pulumi.aws.kinesisanalyticsv2.ApplicationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationCloudwatchLoggingOptionsArgs;
    import java.util.List;
    import java.util.ArrayList;
    import java.util.Map;
    import java.io.File;
    import java.nio.file.Files;
    import java.nio.file.Paths;
    
    public class App {
        public static void main(String[] args) {
            Pulumi.run(App::stack);
        }
    
        public static void stack(Context ctx) {
            var example = new LogGroup("example", LogGroupArgs.builder()
                .name("example-sql-application")
                .build());
    
            var exampleLogStream = new LogStream("exampleLogStream", LogStreamArgs.builder()
                .name("example-sql-application")
                .logGroupName(example.name())
                .build());
    
            var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()
                .name("example-sql-application")
                .runtimeEnvironment("SQL-1_0")
                .serviceExecutionRole(exampleAwsIamRole.arn())
                .applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
                    .applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
                        .codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
                            .textContent("""
    SELECT 1;
                            """)
                            .build())
                        .codeContentType("PLAINTEXT")
                        .build())
                    .sqlApplicationConfiguration(ApplicationApplicationConfigurationSqlApplicationConfigurationArgs.builder()
                        .input(ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs.builder()
                            .namePrefix("PREFIX_1")
                            .inputParallelism(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs.builder()
                                .count(3)
                                .build())
                            .inputSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs.builder()
                                .recordColumns(                            
                                    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs.builder()
                                        .name("COLUMN_1")
                                        .sqlType("VARCHAR(8)")
                                        .mapping("MAPPING-1")
                                        .build(),
                                    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs.builder()
                                        .name("COLUMN_2")
                                        .sqlType("DOUBLE")
                                        .build())
                                .recordEncoding("UTF-8")
                                .recordFormat(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs.builder()
                                    .recordFormatType("CSV")
                                    .mappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs.builder()
                                        .csvMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs.builder()
                                            .recordColumnDelimiter(",")
                                            .recordRowDelimiter("""
    
                                            """)
                                            .build())
                                        .build())
                                    .build())
                                .build())
                            .kinesisStreamsInput(ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs.builder()
                                .resourceArn(exampleAwsKinesisStream.arn())
                                .build())
                            .build())
                        .outputs(                    
                            ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs.builder()
                                .name("OUTPUT_1")
                                .destinationSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs.builder()
                                    .recordFormatType("JSON")
                                    .build())
                                .lambdaOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs.builder()
                                    .resourceArn(exampleAwsLambdaFunction.arn())
                                    .build())
                                .build(),
                            ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs.builder()
                                .name("OUTPUT_2")
                                .destinationSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs.builder()
                                    .recordFormatType("CSV")
                                    .build())
                                .kinesisFirehoseOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs.builder()
                                    .resourceArn(exampleAwsKinesisFirehoseDeliveryStream.arn())
                                    .build())
                                .build())
                        .referenceDataSource(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs.builder()
                            .tableName("TABLE-1")
                            .referenceSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs.builder()
                                .recordColumns(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs.builder()
                                    .name("COLUMN_1")
                                    .sqlType("INTEGER")
                                    .build())
                                .recordFormat(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs.builder()
                                    .recordFormatType("JSON")
                                    .mappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs.builder()
                                        .jsonMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs.builder()
                                            .recordRowPath("$")
                                            .build())
                                        .build())
                                    .build())
                                .build())
                            .s3ReferenceDataSource(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs.builder()
                                .bucketArn(exampleAwsS3Bucket.arn())
                                .fileKey("KEY-1")
                                .build())
                            .build())
                        .build())
                    .build())
                .cloudwatchLoggingOptions(ApplicationCloudwatchLoggingOptionsArgs.builder()
                    .logStreamArn(exampleLogStream.arn())
                    .build())
                .build());
    
        }
    }
    
    resources:
      example:
        type: aws:cloudwatch:LogGroup
        properties:
          name: example-sql-application
      exampleLogStream:
        type: aws:cloudwatch:LogStream
        name: example
        properties:
          name: example-sql-application
          logGroupName: ${example.name}
      exampleApplication:
        type: aws:kinesisanalyticsv2:Application
        name: example
        properties:
          name: example-sql-application
          runtimeEnvironment: SQL-1_0
          serviceExecutionRole: ${exampleAwsIamRole.arn}
          applicationConfiguration:
            applicationCodeConfiguration:
              codeContent:
                textContent: |
                  SELECT 1;              
              codeContentType: PLAINTEXT
            sqlApplicationConfiguration:
              input:
                namePrefix: PREFIX_1
                inputParallelism:
                  count: 3
                inputSchema:
                  recordColumns:
                    - name: COLUMN_1
                      sqlType: VARCHAR(8)
                      mapping: MAPPING-1
                    - name: COLUMN_2
                      sqlType: DOUBLE
                  recordEncoding: UTF-8
                  recordFormat:
                    recordFormatType: CSV
                    mappingParameters:
                      csvMappingParameters:
                        recordColumnDelimiter: ','
                        recordRowDelimiter: |2+
                kinesisStreamsInput:
                  resourceArn: ${exampleAwsKinesisStream.arn}
              outputs:
                - name: OUTPUT_1
                  destinationSchema:
                    recordFormatType: JSON
                  lambdaOutput:
                    resourceArn: ${exampleAwsLambdaFunction.arn}
                - name: OUTPUT_2
                  destinationSchema:
                    recordFormatType: CSV
                  kinesisFirehoseOutput:
                    resourceArn: ${exampleAwsKinesisFirehoseDeliveryStream.arn}
              referenceDataSource:
                tableName: TABLE-1
                referenceSchema:
                  recordColumns:
                    - name: COLUMN_1
                      sqlType: INTEGER
                  recordFormat:
                    recordFormatType: JSON
                    mappingParameters:
                      jsonMappingParameters:
                        recordRowPath: $
                s3ReferenceDataSource:
                  bucketArn: ${exampleAwsS3Bucket.arn}
                  fileKey: KEY-1
          cloudwatchLoggingOptions:
            logStreamArn: ${exampleLogStream.arn}
    

    VPC Configuration

    import * as pulumi from "@pulumi/pulumi";
    import * as aws from "@pulumi/aws";
    
    const example = new aws.s3.BucketV2("example", {bucket: "example-flink-application"});
    const exampleBucketObjectv2 = new aws.s3.BucketObjectv2("example", {
        bucket: example.id,
        key: "example-flink-application",
        source: new pulumi.asset.FileAsset("flink-app.jar"),
    });
    const exampleApplication = new aws.kinesisanalyticsv2.Application("example", {
        name: "example-flink-application",
        runtimeEnvironment: "FLINK-1_8",
        serviceExecutionRole: exampleAwsIamRole.arn,
        applicationConfiguration: {
            applicationCodeConfiguration: {
                codeContent: {
                    s3ContentLocation: {
                        bucketArn: example.arn,
                        fileKey: exampleBucketObjectv2.key,
                    },
                },
                codeContentType: "ZIPFILE",
            },
            vpcConfiguration: {
                securityGroupIds: [
                    exampleAwsSecurityGroup[0].id,
                    exampleAwsSecurityGroup[1].id,
                ],
                subnetIds: [exampleAwsSubnet.id],
            },
        },
    });
    
    import pulumi
    import pulumi_aws as aws
    
    example = aws.s3.BucketV2("example", bucket="example-flink-application")
    example_bucket_objectv2 = aws.s3.BucketObjectv2("example",
        bucket=example.id,
        key="example-flink-application",
        source=pulumi.FileAsset("flink-app.jar"))
    example_application = aws.kinesisanalyticsv2.Application("example",
        name="example-flink-application",
        runtime_environment="FLINK-1_8",
        service_execution_role=example_aws_iam_role["arn"],
        application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationArgs(
            application_code_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs(
                code_content=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs(
                    s3_content_location=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs(
                        bucket_arn=example.arn,
                        file_key=example_bucket_objectv2.key,
                    ),
                ),
                code_content_type="ZIPFILE",
            ),
            vpc_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationVpcConfigurationArgs(
                security_group_ids=[
                    example_aws_security_group[0]["id"],
                    example_aws_security_group[1]["id"],
                ],
                subnet_ids=[example_aws_subnet["id"]],
            ),
        ))
    
    package main
    
    import (
    	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/kinesisanalyticsv2"
    	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/s3"
    	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
    )
    
    func main() {
    	pulumi.Run(func(ctx *pulumi.Context) error {
    		example, err := s3.NewBucketV2(ctx, "example", &s3.BucketV2Args{
    			Bucket: pulumi.String("example-flink-application"),
    		})
    		if err != nil {
    			return err
    		}
    		exampleBucketObjectv2, err := s3.NewBucketObjectv2(ctx, "example", &s3.BucketObjectv2Args{
    			Bucket: example.ID(),
    			Key:    pulumi.String("example-flink-application"),
    			Source: pulumi.NewFileAsset("flink-app.jar"),
    		})
    		if err != nil {
    			return err
    		}
    		_, err = kinesisanalyticsv2.NewApplication(ctx, "example", &kinesisanalyticsv2.ApplicationArgs{
    			Name:                 pulumi.String("example-flink-application"),
    			RuntimeEnvironment:   pulumi.String("FLINK-1_8"),
    			ServiceExecutionRole: pulumi.Any(exampleAwsIamRole.Arn),
    			ApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationArgs{
    				ApplicationCodeConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs{
    					CodeContent: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs{
    						S3ContentLocation: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs{
    							BucketArn: example.Arn,
    							FileKey:   exampleBucketObjectv2.Key,
    						},
    					},
    					CodeContentType: pulumi.String("ZIPFILE"),
    				},
    				VpcConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationVpcConfigurationArgs{
    					SecurityGroupIds: pulumi.StringArray{
    						exampleAwsSecurityGroup[0].Id,
    						exampleAwsSecurityGroup[1].Id,
    					},
    					SubnetIds: pulumi.StringArray{
    						exampleAwsSubnet.Id,
    					},
    				},
    			},
    		})
    		if err != nil {
    			return err
    		}
    		return nil
    	})
    }
    
    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using Aws = Pulumi.Aws;
    
    return await Deployment.RunAsync(() => 
    {
        var example = new Aws.S3.BucketV2("example", new()
        {
            Bucket = "example-flink-application",
        });
    
        var exampleBucketObjectv2 = new Aws.S3.BucketObjectv2("example", new()
        {
            Bucket = example.Id,
            Key = "example-flink-application",
            Source = new FileAsset("flink-app.jar"),
        });
    
        var exampleApplication = new Aws.KinesisAnalyticsV2.Application("example", new()
        {
            Name = "example-flink-application",
            RuntimeEnvironment = "FLINK-1_8",
            ServiceExecutionRole = exampleAwsIamRole.Arn,
            ApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationArgs
            {
                ApplicationCodeConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs
                {
                    CodeContent = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs
                    {
                        S3ContentLocation = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs
                        {
                            BucketArn = example.Arn,
                            FileKey = exampleBucketObjectv2.Key,
                        },
                    },
                    CodeContentType = "ZIPFILE",
                },
                VpcConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationVpcConfigurationArgs
                {
                    SecurityGroupIds = new[]
                    {
                        exampleAwsSecurityGroup[0].Id,
                        exampleAwsSecurityGroup[1].Id,
                    },
                    SubnetIds = new[]
                    {
                        exampleAwsSubnet.Id,
                    },
                },
            },
        });
    
    });
    
    package generated_program;
    
    import com.pulumi.Context;
    import com.pulumi.Pulumi;
    import com.pulumi.core.Output;
    import com.pulumi.aws.s3.BucketV2;
    import com.pulumi.aws.s3.BucketV2Args;
    import com.pulumi.aws.s3.BucketObjectv2;
    import com.pulumi.aws.s3.BucketObjectv2Args;
    import com.pulumi.aws.kinesisanalyticsv2.Application;
    import com.pulumi.aws.kinesisanalyticsv2.ApplicationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs;
    import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationVpcConfigurationArgs;
    import com.pulumi.asset.FileAsset;
    import java.util.List;
    import java.util.ArrayList;
    import java.util.Map;
    import java.io.File;
    import java.nio.file.Files;
    import java.nio.file.Paths;
    
    public class App {
        public static void main(String[] args) {
            Pulumi.run(App::stack);
        }
    
        public static void stack(Context ctx) {
            var example = new BucketV2("example", BucketV2Args.builder()
                .bucket("example-flink-application")
                .build());
    
            var exampleBucketObjectv2 = new BucketObjectv2("exampleBucketObjectv2", BucketObjectv2Args.builder()
                .bucket(example.id())
                .key("example-flink-application")
                .source(new FileAsset("flink-app.jar"))
                .build());
    
            var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()
                .name("example-flink-application")
                .runtimeEnvironment("FLINK-1_8")
                .serviceExecutionRole(exampleAwsIamRole.arn())
                .applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
                    .applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
                        .codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
                            .s3ContentLocation(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs.builder()
                                .bucketArn(example.arn())
                                .fileKey(exampleBucketObjectv2.key())
                                .build())
                            .build())
                        .codeContentType("ZIPFILE")
                        .build())
                    .vpcConfiguration(ApplicationApplicationConfigurationVpcConfigurationArgs.builder()
                        .securityGroupIds(                    
                            exampleAwsSecurityGroup[0].id(),
                            exampleAwsSecurityGroup[1].id())
                        .subnetIds(exampleAwsSubnet.id())
                        .build())
                    .build())
                .build());
    
        }
    }
    
    resources:
      example:
        type: aws:s3:BucketV2
        properties:
          bucket: example-flink-application
      exampleBucketObjectv2:
        type: aws:s3:BucketObjectv2
        name: example
        properties:
          bucket: ${example.id}
          key: example-flink-application
          source:
            fn::FileAsset: flink-app.jar
      exampleApplication:
        type: aws:kinesisanalyticsv2:Application
        name: example
        properties:
          name: example-flink-application
          runtimeEnvironment: FLINK-1_8
          serviceExecutionRole: ${exampleAwsIamRole.arn}
          applicationConfiguration:
            applicationCodeConfiguration:
              codeContent:
                s3ContentLocation:
                  bucketArn: ${example.arn}
                  fileKey: ${exampleBucketObjectv2.key}
              codeContentType: ZIPFILE
            vpcConfiguration:
              securityGroupIds:
                - ${exampleAwsSecurityGroup[0].id}
                - ${exampleAwsSecurityGroup[1].id}
              subnetIds:
                - ${exampleAwsSubnet.id}
    

    Create Application Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new Application(name: string, args: ApplicationArgs, opts?: CustomResourceOptions);
    @overload
    def Application(resource_name: str,
                    args: ApplicationArgs,
                    opts: Optional[ResourceOptions] = None)
    
    @overload
    def Application(resource_name: str,
                    opts: Optional[ResourceOptions] = None,
                    runtime_environment: Optional[str] = None,
                    service_execution_role: Optional[str] = None,
                    application_configuration: Optional[ApplicationApplicationConfigurationArgs] = None,
                    application_mode: Optional[str] = None,
                    cloudwatch_logging_options: Optional[ApplicationCloudwatchLoggingOptionsArgs] = None,
                    description: Optional[str] = None,
                    force_stop: Optional[bool] = None,
                    name: Optional[str] = None,
                    start_application: Optional[bool] = None,
                    tags: Optional[Mapping[str, str]] = None)
    func NewApplication(ctx *Context, name string, args ApplicationArgs, opts ...ResourceOption) (*Application, error)
    public Application(string name, ApplicationArgs args, CustomResourceOptions? opts = null)
    public Application(String name, ApplicationArgs args)
    public Application(String name, ApplicationArgs args, CustomResourceOptions options)
    
    type: aws:kinesisanalyticsv2:Application
    properties: # The arguments to resource properties.
    options: # Bag of options to control resource's behavior.
    
    

    Parameters

    name string
    The unique name of the resource.
    args ApplicationArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args ApplicationArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control resource's behavior.
    ctx Context
    Context object for the current deployment.
    name string
    The unique name of the resource.
    args ApplicationArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args ApplicationArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args ApplicationArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Example

    The following reference example uses placeholder values for all input properties.

    var exampleapplicationResourceResourceFromKinesisanalyticsv2application = new Aws.KinesisAnalyticsV2.Application("exampleapplicationResourceResourceFromKinesisanalyticsv2application", new()
    {
        RuntimeEnvironment = "string",
        ServiceExecutionRole = "string",
        ApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationArgs
        {
            ApplicationCodeConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs
            {
                CodeContentType = "string",
                CodeContent = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs
                {
                    S3ContentLocation = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs
                    {
                        BucketArn = "string",
                        FileKey = "string",
                        ObjectVersion = "string",
                    },
                    TextContent = "string",
                },
            },
            ApplicationSnapshotConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationSnapshotConfigurationArgs
            {
                SnapshotsEnabled = false,
            },
            EnvironmentProperties = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationEnvironmentPropertiesArgs
            {
                PropertyGroups = new[]
                {
                    new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs
                    {
                        PropertyGroupId = "string",
                        PropertyMap = 
                        {
                            { "string", "string" },
                        },
                    },
                },
            },
            FlinkApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs
            {
                CheckpointConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs
                {
                    ConfigurationType = "string",
                    CheckpointInterval = 0,
                    CheckpointingEnabled = false,
                    MinPauseBetweenCheckpoints = 0,
                },
                MonitoringConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs
                {
                    ConfigurationType = "string",
                    LogLevel = "string",
                    MetricsLevel = "string",
                },
                ParallelismConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs
                {
                    ConfigurationType = "string",
                    AutoScalingEnabled = false,
                    Parallelism = 0,
                    ParallelismPerKpu = 0,
                },
            },
            RunConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationRunConfigurationArgs
            {
                ApplicationRestoreConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationRunConfigurationApplicationRestoreConfigurationArgs
                {
                    ApplicationRestoreType = "string",
                    SnapshotName = "string",
                },
                FlinkRunConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationRunConfigurationFlinkRunConfigurationArgs
                {
                    AllowNonRestoredState = false,
                },
            },
            SqlApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs
            {
                Input = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs
                {
                    InputSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs
                    {
                        RecordColumns = new[]
                        {
                            new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs
                            {
                                Name = "string",
                                SqlType = "string",
                                Mapping = "string",
                            },
                        },
                        RecordFormat = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs
                        {
                            MappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs
                            {
                                CsvMappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs
                                {
                                    RecordColumnDelimiter = "string",
                                    RecordRowDelimiter = "string",
                                },
                                JsonMappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersJsonMappingParametersArgs
                                {
                                    RecordRowPath = "string",
                                },
                            },
                            RecordFormatType = "string",
                        },
                        RecordEncoding = "string",
                    },
                    NamePrefix = "string",
                    InAppStreamNames = new[]
                    {
                        "string",
                    },
                    InputId = "string",
                    InputParallelism = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs
                    {
                        Count = 0,
                    },
                    InputProcessingConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationArgs
                    {
                        InputLambdaProcessor = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessorArgs
                        {
                            ResourceArn = "string",
                        },
                    },
                    InputStartingPositionConfigurations = new[]
                    {
                        new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfigurationArgs
                        {
                            InputStartingPosition = "string",
                        },
                    },
                    KinesisFirehoseInput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInputArgs
                    {
                        ResourceArn = "string",
                    },
                    KinesisStreamsInput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs
                    {
                        ResourceArn = "string",
                    },
                },
                Outputs = new[]
                {
                    new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs
                    {
                        DestinationSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs
                        {
                            RecordFormatType = "string",
                        },
                        Name = "string",
                        KinesisFirehoseOutput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs
                        {
                            ResourceArn = "string",
                        },
                        KinesisStreamsOutput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutputArgs
                        {
                            ResourceArn = "string",
                        },
                        LambdaOutput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs
                        {
                            ResourceArn = "string",
                        },
                        OutputId = "string",
                    },
                },
                ReferenceDataSource = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs
                {
                    ReferenceSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs
                    {
                        RecordColumns = new[]
                        {
                            new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs
                            {
                                Name = "string",
                                SqlType = "string",
                                Mapping = "string",
                            },
                        },
                        RecordFormat = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs
                        {
                            MappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs
                            {
                                CsvMappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersCsvMappingParametersArgs
                                {
                                    RecordColumnDelimiter = "string",
                                    RecordRowDelimiter = "string",
                                },
                                JsonMappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs
                                {
                                    RecordRowPath = "string",
                                },
                            },
                            RecordFormatType = "string",
                        },
                        RecordEncoding = "string",
                    },
                    S3ReferenceDataSource = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs
                    {
                        BucketArn = "string",
                        FileKey = "string",
                    },
                    TableName = "string",
                    ReferenceId = "string",
                },
            },
            VpcConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationVpcConfigurationArgs
            {
                SecurityGroupIds = new[]
                {
                    "string",
                },
                SubnetIds = new[]
                {
                    "string",
                },
                VpcConfigurationId = "string",
                VpcId = "string",
            },
        },
        ApplicationMode = "string",
        CloudwatchLoggingOptions = new Aws.KinesisAnalyticsV2.Inputs.ApplicationCloudwatchLoggingOptionsArgs
        {
            LogStreamArn = "string",
            CloudwatchLoggingOptionId = "string",
        },
        Description = "string",
        ForceStop = false,
        Name = "string",
        StartApplication = false,
        Tags = 
        {
            { "string", "string" },
        },
    });
    
    example, err := kinesisanalyticsv2.NewApplication(ctx, "exampleapplicationResourceResourceFromKinesisanalyticsv2application", &kinesisanalyticsv2.ApplicationArgs{
    	RuntimeEnvironment:   pulumi.String("string"),
    	ServiceExecutionRole: pulumi.String("string"),
    	ApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationArgs{
    		ApplicationCodeConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs{
    			CodeContentType: pulumi.String("string"),
    			CodeContent: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs{
    				S3ContentLocation: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs{
    					BucketArn:     pulumi.String("string"),
    					FileKey:       pulumi.String("string"),
    					ObjectVersion: pulumi.String("string"),
    				},
    				TextContent: pulumi.String("string"),
    			},
    		},
    		ApplicationSnapshotConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationSnapshotConfigurationArgs{
    			SnapshotsEnabled: pulumi.Bool(false),
    		},
    		EnvironmentProperties: &kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesArgs{
    			PropertyGroups: kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArray{
    				&kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs{
    					PropertyGroupId: pulumi.String("string"),
    					PropertyMap: pulumi.StringMap{
    						"string": pulumi.String("string"),
    					},
    				},
    			},
    		},
    		FlinkApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs{
    			CheckpointConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs{
    				ConfigurationType:          pulumi.String("string"),
    				CheckpointInterval:         pulumi.Int(0),
    				CheckpointingEnabled:       pulumi.Bool(false),
    				MinPauseBetweenCheckpoints: pulumi.Int(0),
    			},
    			MonitoringConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs{
    				ConfigurationType: pulumi.String("string"),
    				LogLevel:          pulumi.String("string"),
    				MetricsLevel:      pulumi.String("string"),
    			},
    			ParallelismConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs{
    				ConfigurationType:  pulumi.String("string"),
    				AutoScalingEnabled: pulumi.Bool(false),
    				Parallelism:        pulumi.Int(0),
    				ParallelismPerKpu:  pulumi.Int(0),
    			},
    		},
    		RunConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationRunConfigurationArgs{
    			ApplicationRestoreConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationRunConfigurationApplicationRestoreConfigurationArgs{
    				ApplicationRestoreType: pulumi.String("string"),
    				SnapshotName:           pulumi.String("string"),
    			},
    			FlinkRunConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationRunConfigurationFlinkRunConfigurationArgs{
    				AllowNonRestoredState: pulumi.Bool(false),
    			},
    		},
    		SqlApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs{
    			Input: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputTypeArgs{
    				InputSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs{
    					RecordColumns: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArray{
    						&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs{
    							Name:    pulumi.String("string"),
    							SqlType: pulumi.String("string"),
    							Mapping: pulumi.String("string"),
    						},
    					},
    					RecordFormat: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs{
    						MappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs{
    							CsvMappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs{
    								RecordColumnDelimiter: pulumi.String("string"),
    								RecordRowDelimiter:    pulumi.String("string"),
    							},
    							JsonMappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersJsonMappingParametersArgs{
    								RecordRowPath: pulumi.String("string"),
    							},
    						},
    						RecordFormatType: pulumi.String("string"),
    					},
    					RecordEncoding: pulumi.String("string"),
    				},
    				NamePrefix: pulumi.String("string"),
    				InAppStreamNames: pulumi.StringArray{
    					pulumi.String("string"),
    				},
    				InputId: pulumi.String("string"),
    				InputParallelism: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs{
    					Count: pulumi.Int(0),
    				},
    				InputProcessingConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationArgs{
    					InputLambdaProcessor: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessorArgs{
    						ResourceArn: pulumi.String("string"),
    					},
    				},
    				InputStartingPositionConfigurations: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfigurationArray{
    					&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfigurationArgs{
    						InputStartingPosition: pulumi.String("string"),
    					},
    				},
    				KinesisFirehoseInput: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInputArgs{
    					ResourceArn: pulumi.String("string"),
    				},
    				KinesisStreamsInput: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs{
    					ResourceArn: pulumi.String("string"),
    				},
    			},
    			Outputs: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArray{
    				&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArgs{
    					DestinationSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs{
    						RecordFormatType: pulumi.String("string"),
    					},
    					Name: pulumi.String("string"),
    					KinesisFirehoseOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs{
    						ResourceArn: pulumi.String("string"),
    					},
    					KinesisStreamsOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutputArgs{
    						ResourceArn: pulumi.String("string"),
    					},
    					LambdaOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs{
    						ResourceArn: pulumi.String("string"),
    					},
    					OutputId: pulumi.String("string"),
    				},
    			},
    			ReferenceDataSource: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs{
    				ReferenceSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs{
    					RecordColumns: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArray{
    						&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs{
    							Name:    pulumi.String("string"),
    							SqlType: pulumi.String("string"),
    							Mapping: pulumi.String("string"),
    						},
    					},
    					RecordFormat: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs{
    						MappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs{
    							CsvMappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersCsvMappingParametersArgs{
    								RecordColumnDelimiter: pulumi.String("string"),
    								RecordRowDelimiter:    pulumi.String("string"),
    							},
    							JsonMappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs{
    								RecordRowPath: pulumi.String("string"),
    							},
    						},
    						RecordFormatType: pulumi.String("string"),
    					},
    					RecordEncoding: pulumi.String("string"),
    				},
    				S3ReferenceDataSource: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs{
    					BucketArn: pulumi.String("string"),
    					FileKey:   pulumi.String("string"),
    				},
    				TableName:   pulumi.String("string"),
    				ReferenceId: pulumi.String("string"),
    			},
    		},
    		VpcConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationVpcConfigurationArgs{
    			SecurityGroupIds: pulumi.StringArray{
    				pulumi.String("string"),
    			},
    			SubnetIds: pulumi.StringArray{
    				pulumi.String("string"),
    			},
    			VpcConfigurationId: pulumi.String("string"),
    			VpcId:              pulumi.String("string"),
    		},
    	},
    	ApplicationMode: pulumi.String("string"),
    	CloudwatchLoggingOptions: &kinesisanalyticsv2.ApplicationCloudwatchLoggingOptionsArgs{
    		LogStreamArn:              pulumi.String("string"),
    		CloudwatchLoggingOptionId: pulumi.String("string"),
    	},
    	Description:      pulumi.String("string"),
    	ForceStop:        pulumi.Bool(false),
    	Name:             pulumi.String("string"),
    	StartApplication: pulumi.Bool(false),
    	Tags: pulumi.StringMap{
    		"string": pulumi.String("string"),
    	},
    })
    
    var exampleapplicationResourceResourceFromKinesisanalyticsv2application = new Application("exampleapplicationResourceResourceFromKinesisanalyticsv2application", ApplicationArgs.builder()
        .runtimeEnvironment("string")
        .serviceExecutionRole("string")
        .applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
            .applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
                .codeContentType("string")
                .codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
                    .s3ContentLocation(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs.builder()
                        .bucketArn("string")
                        .fileKey("string")
                        .objectVersion("string")
                        .build())
                    .textContent("string")
                    .build())
                .build())
            .applicationSnapshotConfiguration(ApplicationApplicationConfigurationApplicationSnapshotConfigurationArgs.builder()
                .snapshotsEnabled(false)
                .build())
            .environmentProperties(ApplicationApplicationConfigurationEnvironmentPropertiesArgs.builder()
                .propertyGroups(ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs.builder()
                    .propertyGroupId("string")
                    .propertyMap(Map.of("string", "string"))
                    .build())
                .build())
            .flinkApplicationConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs.builder()
                .checkpointConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs.builder()
                    .configurationType("string")
                    .checkpointInterval(0)
                    .checkpointingEnabled(false)
                    .minPauseBetweenCheckpoints(0)
                    .build())
                .monitoringConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs.builder()
                    .configurationType("string")
                    .logLevel("string")
                    .metricsLevel("string")
                    .build())
                .parallelismConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.builder()
                    .configurationType("string")
                    .autoScalingEnabled(false)
                    .parallelism(0)
                    .parallelismPerKpu(0)
                    .build())
                .build())
            .runConfiguration(ApplicationApplicationConfigurationRunConfigurationArgs.builder()
                .applicationRestoreConfiguration(ApplicationApplicationConfigurationRunConfigurationApplicationRestoreConfigurationArgs.builder()
                    .applicationRestoreType("string")
                    .snapshotName("string")
                    .build())
                .flinkRunConfiguration(ApplicationApplicationConfigurationRunConfigurationFlinkRunConfigurationArgs.builder()
                    .allowNonRestoredState(false)
                    .build())
                .build())
            .sqlApplicationConfiguration(ApplicationApplicationConfigurationSqlApplicationConfigurationArgs.builder()
                .input(ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs.builder()
                    .inputSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs.builder()
                        .recordColumns(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs.builder()
                            .name("string")
                            .sqlType("string")
                            .mapping("string")
                            .build())
                        .recordFormat(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs.builder()
                            .mappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs.builder()
                                .csvMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs.builder()
                                    .recordColumnDelimiter("string")
                                    .recordRowDelimiter("string")
                                    .build())
                                .jsonMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersJsonMappingParametersArgs.builder()
                                    .recordRowPath("string")
                                    .build())
                                .build())
                            .recordFormatType("string")
                            .build())
                        .recordEncoding("string")
                        .build())
                    .namePrefix("string")
                    .inAppStreamNames("string")
                    .inputId("string")
                    .inputParallelism(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs.builder()
                        .count(0)
                        .build())
                    .inputProcessingConfiguration(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationArgs.builder()
                        .inputLambdaProcessor(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessorArgs.builder()
                            .resourceArn("string")
                            .build())
                        .build())
                    .inputStartingPositionConfigurations(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfigurationArgs.builder()
                        .inputStartingPosition("string")
                        .build())
                    .kinesisFirehoseInput(ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInputArgs.builder()
                        .resourceArn("string")
                        .build())
                    .kinesisStreamsInput(ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs.builder()
                        .resourceArn("string")
                        .build())
                    .build())
                .outputs(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs.builder()
                    .destinationSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs.builder()
                        .recordFormatType("string")
                        .build())
                    .name("string")
                    .kinesisFirehoseOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs.builder()
                        .resourceArn("string")
                        .build())
                    .kinesisStreamsOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutputArgs.builder()
                        .resourceArn("string")
                        .build())
                    .lambdaOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs.builder()
                        .resourceArn("string")
                        .build())
                    .outputId("string")
                    .build())
                .referenceDataSource(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs.builder()
                    .referenceSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs.builder()
                        .recordColumns(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs.builder()
                            .name("string")
                            .sqlType("string")
                            .mapping("string")
                            .build())
                        .recordFormat(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs.builder()
                            .mappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs.builder()
                                .csvMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersCsvMappingParametersArgs.builder()
                                    .recordColumnDelimiter("string")
                                    .recordRowDelimiter("string")
                                    .build())
                                .jsonMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs.builder()
                                    .recordRowPath("string")
                                    .build())
                                .build())
                            .recordFormatType("string")
                            .build())
                        .recordEncoding("string")
                        .build())
                    .s3ReferenceDataSource(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs.builder()
                        .bucketArn("string")
                        .fileKey("string")
                        .build())
                    .tableName("string")
                    .referenceId("string")
                    .build())
                .build())
            .vpcConfiguration(ApplicationApplicationConfigurationVpcConfigurationArgs.builder()
                .securityGroupIds("string")
                .subnetIds("string")
                .vpcConfigurationId("string")
                .vpcId("string")
                .build())
            .build())
        .applicationMode("string")
        .cloudwatchLoggingOptions(ApplicationCloudwatchLoggingOptionsArgs.builder()
            .logStreamArn("string")
            .cloudwatchLoggingOptionId("string")
            .build())
        .description("string")
        .forceStop(false)
        .name("string")
        .startApplication(false)
        .tags(Map.of("string", "string"))
        .build());
    
    exampleapplication_resource_resource_from_kinesisanalyticsv2application = aws.kinesisanalyticsv2.Application("exampleapplicationResourceResourceFromKinesisanalyticsv2application",
        runtime_environment="string",
        service_execution_role="string",
        application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationArgs(
            application_code_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs(
                code_content_type="string",
                code_content=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs(
                    s3_content_location=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs(
                        bucket_arn="string",
                        file_key="string",
                        object_version="string",
                    ),
                    text_content="string",
                ),
            ),
            application_snapshot_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationSnapshotConfigurationArgs(
                snapshots_enabled=False,
            ),
            environment_properties=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesArgs(
                property_groups=[aws.kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs(
                    property_group_id="string",
                    property_map={
                        "string": "string",
                    },
                )],
            ),
            flink_application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs(
                checkpoint_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs(
                    configuration_type="string",
                    checkpoint_interval=0,
                    checkpointing_enabled=False,
                    min_pause_between_checkpoints=0,
                ),
                monitoring_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs(
                    configuration_type="string",
                    log_level="string",
                    metrics_level="string",
                ),
                parallelism_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs(
                    configuration_type="string",
                    auto_scaling_enabled=False,
                    parallelism=0,
                    parallelism_per_kpu=0,
                ),
            ),
            run_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationRunConfigurationArgs(
                application_restore_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationRunConfigurationApplicationRestoreConfigurationArgs(
                    application_restore_type="string",
                    snapshot_name="string",
                ),
                flink_run_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationRunConfigurationFlinkRunConfigurationArgs(
                    allow_non_restored_state=False,
                ),
            ),
            sql_application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs(
                input=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs(
                    input_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs(
                        record_columns=[aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs(
                            name="string",
                            sql_type="string",
                            mapping="string",
                        )],
                        record_format=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs(
                            mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs(
                                csv_mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs(
                                    record_column_delimiter="string",
                                    record_row_delimiter="string",
                                ),
                                json_mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersJsonMappingParametersArgs(
                                    record_row_path="string",
                                ),
                            ),
                            record_format_type="string",
                        ),
                        record_encoding="string",
                    ),
                    name_prefix="string",
                    in_app_stream_names=["string"],
                    input_id="string",
                    input_parallelism=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs(
                        count=0,
                    ),
                    input_processing_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationArgs(
                        input_lambda_processor=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessorArgs(
                            resource_arn="string",
                        ),
                    ),
                    input_starting_position_configurations=[aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfigurationArgs(
                        input_starting_position="string",
                    )],
                    kinesis_firehose_input=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInputArgs(
                        resource_arn="string",
                    ),
                    kinesis_streams_input=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs(
                        resource_arn="string",
                    ),
                ),
                outputs=[aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs(
                    destination_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs(
                        record_format_type="string",
                    ),
                    name="string",
                    kinesis_firehose_output=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs(
                        resource_arn="string",
                    ),
                    kinesis_streams_output=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutputArgs(
                        resource_arn="string",
                    ),
                    lambda_output=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs(
                        resource_arn="string",
                    ),
                    output_id="string",
                )],
                reference_data_source=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs(
                    reference_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs(
                        record_columns=[aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs(
                            name="string",
                            sql_type="string",
                            mapping="string",
                        )],
                        record_format=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs(
                            mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs(
                                csv_mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersCsvMappingParametersArgs(
                                    record_column_delimiter="string",
                                    record_row_delimiter="string",
                                ),
                                json_mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs(
                                    record_row_path="string",
                                ),
                            ),
                            record_format_type="string",
                        ),
                        record_encoding="string",
                    ),
                    s3_reference_data_source=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs(
                        bucket_arn="string",
                        file_key="string",
                    ),
                    table_name="string",
                    reference_id="string",
                ),
            ),
            vpc_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationVpcConfigurationArgs(
                security_group_ids=["string"],
                subnet_ids=["string"],
                vpc_configuration_id="string",
                vpc_id="string",
            ),
        ),
        application_mode="string",
        cloudwatch_logging_options=aws.kinesisanalyticsv2.ApplicationCloudwatchLoggingOptionsArgs(
            log_stream_arn="string",
            cloudwatch_logging_option_id="string",
        ),
        description="string",
        force_stop=False,
        name="string",
        start_application=False,
        tags={
            "string": "string",
        })
    
    const exampleapplicationResourceResourceFromKinesisanalyticsv2application = new aws.kinesisanalyticsv2.Application("exampleapplicationResourceResourceFromKinesisanalyticsv2application", {
        runtimeEnvironment: "string",
        serviceExecutionRole: "string",
        applicationConfiguration: {
            applicationCodeConfiguration: {
                codeContentType: "string",
                codeContent: {
                    s3ContentLocation: {
                        bucketArn: "string",
                        fileKey: "string",
                        objectVersion: "string",
                    },
                    textContent: "string",
                },
            },
            applicationSnapshotConfiguration: {
                snapshotsEnabled: false,
            },
            environmentProperties: {
                propertyGroups: [{
                    propertyGroupId: "string",
                    propertyMap: {
                        string: "string",
                    },
                }],
            },
            flinkApplicationConfiguration: {
                checkpointConfiguration: {
                    configurationType: "string",
                    checkpointInterval: 0,
                    checkpointingEnabled: false,
                    minPauseBetweenCheckpoints: 0,
                },
                monitoringConfiguration: {
                    configurationType: "string",
                    logLevel: "string",
                    metricsLevel: "string",
                },
                parallelismConfiguration: {
                    configurationType: "string",
                    autoScalingEnabled: false,
                    parallelism: 0,
                    parallelismPerKpu: 0,
                },
            },
            runConfiguration: {
                applicationRestoreConfiguration: {
                    applicationRestoreType: "string",
                    snapshotName: "string",
                },
                flinkRunConfiguration: {
                    allowNonRestoredState: false,
                },
            },
            sqlApplicationConfiguration: {
                input: {
                    inputSchema: {
                        recordColumns: [{
                            name: "string",
                            sqlType: "string",
                            mapping: "string",
                        }],
                        recordFormat: {
                            mappingParameters: {
                                csvMappingParameters: {
                                    recordColumnDelimiter: "string",
                                    recordRowDelimiter: "string",
                                },
                                jsonMappingParameters: {
                                    recordRowPath: "string",
                                },
                            },
                            recordFormatType: "string",
                        },
                        recordEncoding: "string",
                    },
                    namePrefix: "string",
                    inAppStreamNames: ["string"],
                    inputId: "string",
                    inputParallelism: {
                        count: 0,
                    },
                    inputProcessingConfiguration: {
                        inputLambdaProcessor: {
                            resourceArn: "string",
                        },
                    },
                    inputStartingPositionConfigurations: [{
                        inputStartingPosition: "string",
                    }],
                    kinesisFirehoseInput: {
                        resourceArn: "string",
                    },
                    kinesisStreamsInput: {
                        resourceArn: "string",
                    },
                },
                outputs: [{
                    destinationSchema: {
                        recordFormatType: "string",
                    },
                    name: "string",
                    kinesisFirehoseOutput: {
                        resourceArn: "string",
                    },
                    kinesisStreamsOutput: {
                        resourceArn: "string",
                    },
                    lambdaOutput: {
                        resourceArn: "string",
                    },
                    outputId: "string",
                }],
                referenceDataSource: {
                    referenceSchema: {
                        recordColumns: [{
                            name: "string",
                            sqlType: "string",
                            mapping: "string",
                        }],
                        recordFormat: {
                            mappingParameters: {
                                csvMappingParameters: {
                                    recordColumnDelimiter: "string",
                                    recordRowDelimiter: "string",
                                },
                                jsonMappingParameters: {
                                    recordRowPath: "string",
                                },
                            },
                            recordFormatType: "string",
                        },
                        recordEncoding: "string",
                    },
                    s3ReferenceDataSource: {
                        bucketArn: "string",
                        fileKey: "string",
                    },
                    tableName: "string",
                    referenceId: "string",
                },
            },
            vpcConfiguration: {
                securityGroupIds: ["string"],
                subnetIds: ["string"],
                vpcConfigurationId: "string",
                vpcId: "string",
            },
        },
        applicationMode: "string",
        cloudwatchLoggingOptions: {
            logStreamArn: "string",
            cloudwatchLoggingOptionId: "string",
        },
        description: "string",
        forceStop: false,
        name: "string",
        startApplication: false,
        tags: {
            string: "string",
        },
    });
    
    type: aws:kinesisanalyticsv2:Application
    properties:
        applicationConfiguration:
            applicationCodeConfiguration:
                codeContent:
                    s3ContentLocation:
                        bucketArn: string
                        fileKey: string
                        objectVersion: string
                    textContent: string
                codeContentType: string
            applicationSnapshotConfiguration:
                snapshotsEnabled: false
            environmentProperties:
                propertyGroups:
                    - propertyGroupId: string
                      propertyMap:
                        string: string
            flinkApplicationConfiguration:
                checkpointConfiguration:
                    checkpointInterval: 0
                    checkpointingEnabled: false
                    configurationType: string
                    minPauseBetweenCheckpoints: 0
                monitoringConfiguration:
                    configurationType: string
                    logLevel: string
                    metricsLevel: string
                parallelismConfiguration:
                    autoScalingEnabled: false
                    configurationType: string
                    parallelism: 0
                    parallelismPerKpu: 0
            runConfiguration:
                applicationRestoreConfiguration:
                    applicationRestoreType: string
                    snapshotName: string
                flinkRunConfiguration:
                    allowNonRestoredState: false
            sqlApplicationConfiguration:
                input:
                    inAppStreamNames:
                        - string
                    inputId: string
                    inputParallelism:
                        count: 0
                    inputProcessingConfiguration:
                        inputLambdaProcessor:
                            resourceArn: string
                    inputSchema:
                        recordColumns:
                            - mapping: string
                              name: string
                              sqlType: string
                        recordEncoding: string
                        recordFormat:
                            mappingParameters:
                                csvMappingParameters:
                                    recordColumnDelimiter: string
                                    recordRowDelimiter: string
                                jsonMappingParameters:
                                    recordRowPath: string
                            recordFormatType: string
                    inputStartingPositionConfigurations:
                        - inputStartingPosition: string
                    kinesisFirehoseInput:
                        resourceArn: string
                    kinesisStreamsInput:
                        resourceArn: string
                    namePrefix: string
                outputs:
                    - destinationSchema:
                        recordFormatType: string
                      kinesisFirehoseOutput:
                        resourceArn: string
                      kinesisStreamsOutput:
                        resourceArn: string
                      lambdaOutput:
                        resourceArn: string
                      name: string
                      outputId: string
                referenceDataSource:
                    referenceId: string
                    referenceSchema:
                        recordColumns:
                            - mapping: string
                              name: string
                              sqlType: string
                        recordEncoding: string
                        recordFormat:
                            mappingParameters:
                                csvMappingParameters:
                                    recordColumnDelimiter: string
                                    recordRowDelimiter: string
                                jsonMappingParameters:
                                    recordRowPath: string
                            recordFormatType: string
                    s3ReferenceDataSource:
                        bucketArn: string
                        fileKey: string
                    tableName: string
            vpcConfiguration:
                securityGroupIds:
                    - string
                subnetIds:
                    - string
                vpcConfigurationId: string
                vpcId: string
        applicationMode: string
        cloudwatchLoggingOptions:
            cloudwatchLoggingOptionId: string
            logStreamArn: string
        description: string
        forceStop: false
        name: string
        runtimeEnvironment: string
        serviceExecutionRole: string
        startApplication: false
        tags:
            string: string
    

    Application Resource Properties

    To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

    Inputs

    The Application resource accepts the following input properties:

    RuntimeEnvironment string
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    ServiceExecutionRole string
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    ApplicationConfiguration ApplicationApplicationConfiguration
    The application's configuration
    ApplicationMode string
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    CloudwatchLoggingOptions ApplicationCloudwatchLoggingOptions
    A CloudWatch log stream to monitor application configuration errors.
    Description string
    A summary description of the application.
    ForceStop bool
    Whether to force stop an unresponsive Flink-based application.
    Name string
    The name of the application.
    StartApplication bool
    Whether to start or stop the application.
    Tags Dictionary<string, string>
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    RuntimeEnvironment string
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    ServiceExecutionRole string
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    ApplicationConfiguration ApplicationApplicationConfigurationArgs
    The application's configuration
    ApplicationMode string
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    CloudwatchLoggingOptions ApplicationCloudwatchLoggingOptionsArgs
    A CloudWatch log stream to monitor application configuration errors.
    Description string
    A summary description of the application.
    ForceStop bool
    Whether to force stop an unresponsive Flink-based application.
    Name string
    The name of the application.
    StartApplication bool
    Whether to start or stop the application.
    Tags map[string]string
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    runtimeEnvironment String
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    serviceExecutionRole String
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    applicationConfiguration ApplicationApplicationConfiguration
    The application's configuration
    applicationMode String
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    cloudwatchLoggingOptions ApplicationCloudwatchLoggingOptions
    A CloudWatch log stream to monitor application configuration errors.
    description String
    A summary description of the application.
    forceStop Boolean
    Whether to force stop an unresponsive Flink-based application.
    name String
    The name of the application.
    startApplication Boolean
    Whether to start or stop the application.
    tags Map<String,String>
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    runtimeEnvironment string
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    serviceExecutionRole string
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    applicationConfiguration ApplicationApplicationConfiguration
    The application's configuration
    applicationMode string
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    cloudwatchLoggingOptions ApplicationCloudwatchLoggingOptions
    A CloudWatch log stream to monitor application configuration errors.
    description string
    A summary description of the application.
    forceStop boolean
    Whether to force stop an unresponsive Flink-based application.
    name string
    The name of the application.
    startApplication boolean
    Whether to start or stop the application.
    tags {[key: string]: string}
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    runtime_environment str
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    service_execution_role str
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    application_configuration ApplicationApplicationConfigurationArgs
    The application's configuration
    application_mode str
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    cloudwatch_logging_options ApplicationCloudwatchLoggingOptionsArgs
    A CloudWatch log stream to monitor application configuration errors.
    description str
    A summary description of the application.
    force_stop bool
    Whether to force stop an unresponsive Flink-based application.
    name str
    The name of the application.
    start_application bool
    Whether to start or stop the application.
    tags Mapping[str, str]
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    runtimeEnvironment String
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    serviceExecutionRole String
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    applicationConfiguration Property Map
    The application's configuration
    applicationMode String
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    cloudwatchLoggingOptions Property Map
    A CloudWatch log stream to monitor application configuration errors.
    description String
    A summary description of the application.
    forceStop Boolean
    Whether to force stop an unresponsive Flink-based application.
    name String
    The name of the application.
    startApplication Boolean
    Whether to start or stop the application.
    tags Map<String>
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level

    Outputs

    All input properties are implicitly available as output properties. Additionally, the Application resource produces the following output properties:

    Arn string
    The ARN of the application.
    CreateTimestamp string
    The current timestamp when the application was created.
    Id string
    The provider-assigned unique ID for this managed resource.
    LastUpdateTimestamp string
    The current timestamp when the application was last updated.
    Status string
    The status of the application.
    TagsAll Dictionary<string, string>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    VersionId int
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    Arn string
    The ARN of the application.
    CreateTimestamp string
    The current timestamp when the application was created.
    Id string
    The provider-assigned unique ID for this managed resource.
    LastUpdateTimestamp string
    The current timestamp when the application was last updated.
    Status string
    The status of the application.
    TagsAll map[string]string
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    VersionId int
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    arn String
    The ARN of the application.
    createTimestamp String
    The current timestamp when the application was created.
    id String
    The provider-assigned unique ID for this managed resource.
    lastUpdateTimestamp String
    The current timestamp when the application was last updated.
    status String
    The status of the application.
    tagsAll Map<String,String>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    versionId Integer
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    arn string
    The ARN of the application.
    createTimestamp string
    The current timestamp when the application was created.
    id string
    The provider-assigned unique ID for this managed resource.
    lastUpdateTimestamp string
    The current timestamp when the application was last updated.
    status string
    The status of the application.
    tagsAll {[key: string]: string}
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    versionId number
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    arn str
    The ARN of the application.
    create_timestamp str
    The current timestamp when the application was created.
    id str
    The provider-assigned unique ID for this managed resource.
    last_update_timestamp str
    The current timestamp when the application was last updated.
    status str
    The status of the application.
    tags_all Mapping[str, str]
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    version_id int
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    arn String
    The ARN of the application.
    createTimestamp String
    The current timestamp when the application was created.
    id String
    The provider-assigned unique ID for this managed resource.
    lastUpdateTimestamp String
    The current timestamp when the application was last updated.
    status String
    The status of the application.
    tagsAll Map<String>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    versionId Number
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.

    Look up Existing Application Resource

    Get an existing Application resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

    public static get(name: string, id: Input<ID>, state?: ApplicationState, opts?: CustomResourceOptions): Application
    @staticmethod
    def get(resource_name: str,
            id: str,
            opts: Optional[ResourceOptions] = None,
            application_configuration: Optional[ApplicationApplicationConfigurationArgs] = None,
            application_mode: Optional[str] = None,
            arn: Optional[str] = None,
            cloudwatch_logging_options: Optional[ApplicationCloudwatchLoggingOptionsArgs] = None,
            create_timestamp: Optional[str] = None,
            description: Optional[str] = None,
            force_stop: Optional[bool] = None,
            last_update_timestamp: Optional[str] = None,
            name: Optional[str] = None,
            runtime_environment: Optional[str] = None,
            service_execution_role: Optional[str] = None,
            start_application: Optional[bool] = None,
            status: Optional[str] = None,
            tags: Optional[Mapping[str, str]] = None,
            tags_all: Optional[Mapping[str, str]] = None,
            version_id: Optional[int] = None) -> Application
    func GetApplication(ctx *Context, name string, id IDInput, state *ApplicationState, opts ...ResourceOption) (*Application, error)
    public static Application Get(string name, Input<string> id, ApplicationState? state, CustomResourceOptions? opts = null)
    public static Application get(String name, Output<String> id, ApplicationState state, CustomResourceOptions options)
    Resource lookup is not supported in YAML
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    resource_name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    The following state arguments are supported:
    ApplicationConfiguration ApplicationApplicationConfiguration
    The application's configuration
    ApplicationMode string
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    Arn string
    The ARN of the application.
    CloudwatchLoggingOptions ApplicationCloudwatchLoggingOptions
    A CloudWatch log stream to monitor application configuration errors.
    CreateTimestamp string
    The current timestamp when the application was created.
    Description string
    A summary description of the application.
    ForceStop bool
    Whether to force stop an unresponsive Flink-based application.
    LastUpdateTimestamp string
    The current timestamp when the application was last updated.
    Name string
    The name of the application.
    RuntimeEnvironment string
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    ServiceExecutionRole string
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    StartApplication bool
    Whether to start or stop the application.
    Status string
    The status of the application.
    Tags Dictionary<string, string>
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    TagsAll Dictionary<string, string>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    VersionId int
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    ApplicationConfiguration ApplicationApplicationConfigurationArgs
    The application's configuration
    ApplicationMode string
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    Arn string
    The ARN of the application.
    CloudwatchLoggingOptions ApplicationCloudwatchLoggingOptionsArgs
    A CloudWatch log stream to monitor application configuration errors.
    CreateTimestamp string
    The current timestamp when the application was created.
    Description string
    A summary description of the application.
    ForceStop bool
    Whether to force stop an unresponsive Flink-based application.
    LastUpdateTimestamp string
    The current timestamp when the application was last updated.
    Name string
    The name of the application.
    RuntimeEnvironment string
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    ServiceExecutionRole string
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    StartApplication bool
    Whether to start or stop the application.
    Status string
    The status of the application.
    Tags map[string]string
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    TagsAll map[string]string
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    VersionId int
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    applicationConfiguration ApplicationApplicationConfiguration
    The application's configuration
    applicationMode String
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    arn String
    The ARN of the application.
    cloudwatchLoggingOptions ApplicationCloudwatchLoggingOptions
    A CloudWatch log stream to monitor application configuration errors.
    createTimestamp String
    The current timestamp when the application was created.
    description String
    A summary description of the application.
    forceStop Boolean
    Whether to force stop an unresponsive Flink-based application.
    lastUpdateTimestamp String
    The current timestamp when the application was last updated.
    name String
    The name of the application.
    runtimeEnvironment String
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    serviceExecutionRole String
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    startApplication Boolean
    Whether to start or stop the application.
    status String
    The status of the application.
    tags Map<String,String>
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    tagsAll Map<String,String>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    versionId Integer
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    applicationConfiguration ApplicationApplicationConfiguration
    The application's configuration
    applicationMode string
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    arn string
    The ARN of the application.
    cloudwatchLoggingOptions ApplicationCloudwatchLoggingOptions
    A CloudWatch log stream to monitor application configuration errors.
    createTimestamp string
    The current timestamp when the application was created.
    description string
    A summary description of the application.
    forceStop boolean
    Whether to force stop an unresponsive Flink-based application.
    lastUpdateTimestamp string
    The current timestamp when the application was last updated.
    name string
    The name of the application.
    runtimeEnvironment string
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    serviceExecutionRole string
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    startApplication boolean
    Whether to start or stop the application.
    status string
    The status of the application.
    tags {[key: string]: string}
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    tagsAll {[key: string]: string}
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    versionId number
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    application_configuration ApplicationApplicationConfigurationArgs
    The application's configuration
    application_mode str
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    arn str
    The ARN of the application.
    cloudwatch_logging_options ApplicationCloudwatchLoggingOptionsArgs
    A CloudWatch log stream to monitor application configuration errors.
    create_timestamp str
    The current timestamp when the application was created.
    description str
    A summary description of the application.
    force_stop bool
    Whether to force stop an unresponsive Flink-based application.
    last_update_timestamp str
    The current timestamp when the application was last updated.
    name str
    The name of the application.
    runtime_environment str
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    service_execution_role str
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    start_application bool
    Whether to start or stop the application.
    status str
    The status of the application.
    tags Mapping[str, str]
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    tags_all Mapping[str, str]
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    version_id int
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
    applicationConfiguration Property Map
    The application's configuration
    applicationMode String
    The application's mode. Valid values are STREAMING, INTERACTIVE.
    arn String
    The ARN of the application.
    cloudwatchLoggingOptions Property Map
    A CloudWatch log stream to monitor application configuration errors.
    createTimestamp String
    The current timestamp when the application was created.
    description String
    A summary description of the application.
    forceStop Boolean
    Whether to force stop an unresponsive Flink-based application.
    lastUpdateTimestamp String
    The current timestamp when the application was last updated.
    name String
    The name of the application.
    runtimeEnvironment String
    The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
    serviceExecutionRole String
    The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
    startApplication Boolean
    Whether to start or stop the application.
    status String
    The status of the application.
    tags Map<String>
    A map of tags to assign to the application. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level
    tagsAll Map<String>
    A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

    Deprecated: Please use tags instead.

    versionId Number
    The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.

    Supporting Types

    ApplicationApplicationConfiguration, ApplicationApplicationConfigurationArgs

    ApplicationCodeConfiguration ApplicationApplicationConfigurationApplicationCodeConfiguration
    The code location and type parameters for the application.
    ApplicationSnapshotConfiguration ApplicationApplicationConfigurationApplicationSnapshotConfiguration
    Describes whether snapshots are enabled for a Flink-based application.
    EnvironmentProperties ApplicationApplicationConfigurationEnvironmentProperties
    Describes execution properties for a Flink-based application.
    FlinkApplicationConfiguration ApplicationApplicationConfigurationFlinkApplicationConfiguration
    The configuration of a Flink-based application.
    RunConfiguration ApplicationApplicationConfigurationRunConfiguration
    Describes the starting properties for a Flink-based application.
    SqlApplicationConfiguration ApplicationApplicationConfigurationSqlApplicationConfiguration
    The configuration of a SQL-based application.
    VpcConfiguration ApplicationApplicationConfigurationVpcConfiguration
    The VPC configuration of a Flink-based application.
    ApplicationCodeConfiguration ApplicationApplicationConfigurationApplicationCodeConfiguration
    The code location and type parameters for the application.
    ApplicationSnapshotConfiguration ApplicationApplicationConfigurationApplicationSnapshotConfiguration
    Describes whether snapshots are enabled for a Flink-based application.
    EnvironmentProperties ApplicationApplicationConfigurationEnvironmentProperties
    Describes execution properties for a Flink-based application.
    FlinkApplicationConfiguration ApplicationApplicationConfigurationFlinkApplicationConfiguration
    The configuration of a Flink-based application.
    RunConfiguration ApplicationApplicationConfigurationRunConfiguration
    Describes the starting properties for a Flink-based application.
    SqlApplicationConfiguration ApplicationApplicationConfigurationSqlApplicationConfiguration
    The configuration of a SQL-based application.
    VpcConfiguration ApplicationApplicationConfigurationVpcConfiguration
    The VPC configuration of a Flink-based application.
    applicationCodeConfiguration ApplicationApplicationConfigurationApplicationCodeConfiguration
    The code location and type parameters for the application.
    applicationSnapshotConfiguration ApplicationApplicationConfigurationApplicationSnapshotConfiguration
    Describes whether snapshots are enabled for a Flink-based application.
    environmentProperties ApplicationApplicationConfigurationEnvironmentProperties
    Describes execution properties for a Flink-based application.
    flinkApplicationConfiguration ApplicationApplicationConfigurationFlinkApplicationConfiguration
    The configuration of a Flink-based application.
    runConfiguration ApplicationApplicationConfigurationRunConfiguration
    Describes the starting properties for a Flink-based application.
    sqlApplicationConfiguration ApplicationApplicationConfigurationSqlApplicationConfiguration
    The configuration of a SQL-based application.
    vpcConfiguration ApplicationApplicationConfigurationVpcConfiguration
    The VPC configuration of a Flink-based application.
    applicationCodeConfiguration ApplicationApplicationConfigurationApplicationCodeConfiguration
    The code location and type parameters for the application.
    applicationSnapshotConfiguration ApplicationApplicationConfigurationApplicationSnapshotConfiguration
    Describes whether snapshots are enabled for a Flink-based application.
    environmentProperties ApplicationApplicationConfigurationEnvironmentProperties
    Describes execution properties for a Flink-based application.
    flinkApplicationConfiguration ApplicationApplicationConfigurationFlinkApplicationConfiguration
    The configuration of a Flink-based application.
    runConfiguration ApplicationApplicationConfigurationRunConfiguration
    Describes the starting properties for a Flink-based application.
    sqlApplicationConfiguration ApplicationApplicationConfigurationSqlApplicationConfiguration
    The configuration of a SQL-based application.
    vpcConfiguration ApplicationApplicationConfigurationVpcConfiguration
    The VPC configuration of a Flink-based application.
    application_code_configuration ApplicationApplicationConfigurationApplicationCodeConfiguration
    The code location and type parameters for the application.
    application_snapshot_configuration ApplicationApplicationConfigurationApplicationSnapshotConfiguration
    Describes whether snapshots are enabled for a Flink-based application.
    environment_properties ApplicationApplicationConfigurationEnvironmentProperties
    Describes execution properties for a Flink-based application.
    flink_application_configuration ApplicationApplicationConfigurationFlinkApplicationConfiguration
    The configuration of a Flink-based application.
    run_configuration ApplicationApplicationConfigurationRunConfiguration
    Describes the starting properties for a Flink-based application.
    sql_application_configuration ApplicationApplicationConfigurationSqlApplicationConfiguration
    The configuration of a SQL-based application.
    vpc_configuration ApplicationApplicationConfigurationVpcConfiguration
    The VPC configuration of a Flink-based application.
    applicationCodeConfiguration Property Map
    The code location and type parameters for the application.
    applicationSnapshotConfiguration Property Map
    Describes whether snapshots are enabled for a Flink-based application.
    environmentProperties Property Map
    Describes execution properties for a Flink-based application.
    flinkApplicationConfiguration Property Map
    The configuration of a Flink-based application.
    runConfiguration Property Map
    Describes the starting properties for a Flink-based application.
    sqlApplicationConfiguration Property Map
    The configuration of a SQL-based application.
    vpcConfiguration Property Map
    The VPC configuration of a Flink-based application.

    ApplicationApplicationConfigurationApplicationCodeConfiguration, ApplicationApplicationConfigurationApplicationCodeConfigurationArgs

    CodeContentType string
    Specifies whether the code content is in text or zip format. Valid values: PLAINTEXT, ZIPFILE.
    CodeContent ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContent
    The location and type of the application code.
    CodeContentType string
    Specifies whether the code content is in text or zip format. Valid values: PLAINTEXT, ZIPFILE.
    CodeContent ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContent
    The location and type of the application code.
    codeContentType String
    Specifies whether the code content is in text or zip format. Valid values: PLAINTEXT, ZIPFILE.
    codeContent ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContent
    The location and type of the application code.
    codeContentType string
    Specifies whether the code content is in text or zip format. Valid values: PLAINTEXT, ZIPFILE.
    codeContent ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContent
    The location and type of the application code.
    code_content_type str
    Specifies whether the code content is in text or zip format. Valid values: PLAINTEXT, ZIPFILE.
    code_content ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContent
    The location and type of the application code.
    codeContentType String
    Specifies whether the code content is in text or zip format. Valid values: PLAINTEXT, ZIPFILE.
    codeContent Property Map
    The location and type of the application code.

    ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContent, ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs

    S3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation
    Information about the Amazon S3 bucket containing the application code.
    TextContent string
    The text-format code for the application.
    S3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation
    Information about the Amazon S3 bucket containing the application code.
    TextContent string
    The text-format code for the application.
    s3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation
    Information about the Amazon S3 bucket containing the application code.
    textContent String
    The text-format code for the application.
    s3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation
    Information about the Amazon S3 bucket containing the application code.
    textContent string
    The text-format code for the application.
    s3_content_location ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation
    Information about the Amazon S3 bucket containing the application code.
    text_content str
    The text-format code for the application.
    s3ContentLocation Property Map
    Information about the Amazon S3 bucket containing the application code.
    textContent String
    The text-format code for the application.

    ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation, ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs

    BucketArn string
    The ARN for the S3 bucket containing the application code.
    FileKey string
    The file key for the object containing the application code.
    ObjectVersion string
    The version of the object containing the application code.
    BucketArn string
    The ARN for the S3 bucket containing the application code.
    FileKey string
    The file key for the object containing the application code.
    ObjectVersion string
    The version of the object containing the application code.
    bucketArn String
    The ARN for the S3 bucket containing the application code.
    fileKey String
    The file key for the object containing the application code.
    objectVersion String
    The version of the object containing the application code.
    bucketArn string
    The ARN for the S3 bucket containing the application code.
    fileKey string
    The file key for the object containing the application code.
    objectVersion string
    The version of the object containing the application code.
    bucket_arn str
    The ARN for the S3 bucket containing the application code.
    file_key str
    The file key for the object containing the application code.
    object_version str
    The version of the object containing the application code.
    bucketArn String
    The ARN for the S3 bucket containing the application code.
    fileKey String
    The file key for the object containing the application code.
    objectVersion String
    The version of the object containing the application code.

    ApplicationApplicationConfigurationApplicationSnapshotConfiguration, ApplicationApplicationConfigurationApplicationSnapshotConfigurationArgs

    SnapshotsEnabled bool
    Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
    SnapshotsEnabled bool
    Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
    snapshotsEnabled Boolean
    Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
    snapshotsEnabled boolean
    Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
    snapshots_enabled bool
    Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
    snapshotsEnabled Boolean
    Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.

    ApplicationApplicationConfigurationEnvironmentProperties, ApplicationApplicationConfigurationEnvironmentPropertiesArgs

    propertyGroups List<Property Map>
    Describes the execution property groups.

    ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroup, ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs

    PropertyGroupId string
    The key of the application execution property key-value map.
    PropertyMap Dictionary<string, string>
    Application execution property key-value map.
    PropertyGroupId string
    The key of the application execution property key-value map.
    PropertyMap map[string]string
    Application execution property key-value map.
    propertyGroupId String
    The key of the application execution property key-value map.
    propertyMap Map<String,String>
    Application execution property key-value map.
    propertyGroupId string
    The key of the application execution property key-value map.
    propertyMap {[key: string]: string}
    Application execution property key-value map.
    property_group_id str
    The key of the application execution property key-value map.
    property_map Mapping[str, str]
    Application execution property key-value map.
    propertyGroupId String
    The key of the application execution property key-value map.
    propertyMap Map<String>
    Application execution property key-value map.

    ApplicationApplicationConfigurationFlinkApplicationConfiguration, ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs

    checkpointConfiguration Property Map
    Describes an application's checkpointing configuration.
    monitoringConfiguration Property Map
    Describes configuration parameters for CloudWatch logging for an application.
    parallelismConfiguration Property Map
    Describes parameters for how an application executes multiple tasks simultaneously.

    ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfiguration, ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs

    ConfigurationType string
    Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:

    • checkpointing_enabled = true
    • checkpoint_interval = 60000
    • min_pause_between_checkpoints = 5000
    CheckpointInterval int
    Describes the interval in milliseconds between checkpoint operations.
    CheckpointingEnabled bool
    Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
    MinPauseBetweenCheckpoints int
    Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
    ConfigurationType string
    Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:

    • checkpointing_enabled = true
    • checkpoint_interval = 60000
    • min_pause_between_checkpoints = 5000
    CheckpointInterval int
    Describes the interval in milliseconds between checkpoint operations.
    CheckpointingEnabled bool
    Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
    MinPauseBetweenCheckpoints int
    Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
    configurationType String
    Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:

    • checkpointing_enabled = true
    • checkpoint_interval = 60000
    • min_pause_between_checkpoints = 5000
    checkpointInterval Integer
    Describes the interval in milliseconds between checkpoint operations.
    checkpointingEnabled Boolean
    Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
    minPauseBetweenCheckpoints Integer
    Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
    configurationType string
    Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:

    • checkpointing_enabled = true
    • checkpoint_interval = 60000
    • min_pause_between_checkpoints = 5000
    checkpointInterval number
    Describes the interval in milliseconds between checkpoint operations.
    checkpointingEnabled boolean
    Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
    minPauseBetweenCheckpoints number
    Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
    configuration_type str
    Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:

    • checkpointing_enabled = true
    • checkpoint_interval = 60000
    • min_pause_between_checkpoints = 5000
    checkpoint_interval int
    Describes the interval in milliseconds between checkpoint operations.
    checkpointing_enabled bool
    Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
    min_pause_between_checkpoints int
    Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
    configurationType String
    Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:

    • checkpointing_enabled = true
    • checkpoint_interval = 60000
    • min_pause_between_checkpoints = 5000
    checkpointInterval Number
    Describes the interval in milliseconds between checkpoint operations.
    checkpointingEnabled Boolean
    Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
    minPauseBetweenCheckpoints Number
    Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.

    ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfiguration, ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs

    ConfigurationType string
    Describes whether to use the default CloudWatch logging configuration for an application. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified log_level or metrics_level attribute values to be effective.
    LogLevel string
    Describes the verbosity of the CloudWatch Logs for an application. Valid values: DEBUG, ERROR, INFO, WARN.
    MetricsLevel string
    Describes the granularity of the CloudWatch Logs for an application. Valid values: APPLICATION, OPERATOR, PARALLELISM, TASK.
    ConfigurationType string
    Describes whether to use the default CloudWatch logging configuration for an application. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified log_level or metrics_level attribute values to be effective.
    LogLevel string
    Describes the verbosity of the CloudWatch Logs for an application. Valid values: DEBUG, ERROR, INFO, WARN.
    MetricsLevel string
    Describes the granularity of the CloudWatch Logs for an application. Valid values: APPLICATION, OPERATOR, PARALLELISM, TASK.
    configurationType String
    Describes whether to use the default CloudWatch logging configuration for an application. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified log_level or metrics_level attribute values to be effective.
    logLevel String
    Describes the verbosity of the CloudWatch Logs for an application. Valid values: DEBUG, ERROR, INFO, WARN.
    metricsLevel String
    Describes the granularity of the CloudWatch Logs for an application. Valid values: APPLICATION, OPERATOR, PARALLELISM, TASK.
    configurationType string
    Describes whether to use the default CloudWatch logging configuration for an application. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified log_level or metrics_level attribute values to be effective.
    logLevel string
    Describes the verbosity of the CloudWatch Logs for an application. Valid values: DEBUG, ERROR, INFO, WARN.
    metricsLevel string
    Describes the granularity of the CloudWatch Logs for an application. Valid values: APPLICATION, OPERATOR, PARALLELISM, TASK.
    configuration_type str
    Describes whether to use the default CloudWatch logging configuration for an application. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified log_level or metrics_level attribute values to be effective.
    log_level str
    Describes the verbosity of the CloudWatch Logs for an application. Valid values: DEBUG, ERROR, INFO, WARN.
    metrics_level str
    Describes the granularity of the CloudWatch Logs for an application. Valid values: APPLICATION, OPERATOR, PARALLELISM, TASK.
    configurationType String
    Describes whether to use the default CloudWatch logging configuration for an application. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified log_level or metrics_level attribute values to be effective.
    logLevel String
    Describes the verbosity of the CloudWatch Logs for an application. Valid values: DEBUG, ERROR, INFO, WARN.
    metricsLevel String
    Describes the granularity of the CloudWatch Logs for an application. Valid values: APPLICATION, OPERATOR, PARALLELISM, TASK.

    ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration, ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs

    ConfigurationType string
    Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified auto_scaling_enabled, parallelism, or parallelism_per_kpu attribute values to be effective.
    AutoScalingEnabled bool
    Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
    Parallelism int
    Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.
    ParallelismPerKpu int
    Describes the number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
    ConfigurationType string
    Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified auto_scaling_enabled, parallelism, or parallelism_per_kpu attribute values to be effective.
    AutoScalingEnabled bool
    Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
    Parallelism int
    Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.
    ParallelismPerKpu int
    Describes the number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
    configurationType String
    Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified auto_scaling_enabled, parallelism, or parallelism_per_kpu attribute values to be effective.
    autoScalingEnabled Boolean
    Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
    parallelism Integer
    Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.
    parallelismPerKpu Integer
    Describes the number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
    configurationType string
    Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified auto_scaling_enabled, parallelism, or parallelism_per_kpu attribute values to be effective.
    autoScalingEnabled boolean
    Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
    parallelism number
    Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.
    parallelismPerKpu number
    Describes the number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
    configuration_type str
    Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified auto_scaling_enabled, parallelism, or parallelism_per_kpu attribute values to be effective.
    auto_scaling_enabled bool
    Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
    parallelism int
    Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.
    parallelism_per_kpu int
    Describes the number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
    configurationType String
    Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified auto_scaling_enabled, parallelism, or parallelism_per_kpu attribute values to be effective.
    autoScalingEnabled Boolean
    Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
    parallelism Number
    Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.
    parallelismPerKpu Number
    Describes the number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.

    ApplicationApplicationConfigurationRunConfiguration, ApplicationApplicationConfigurationRunConfigurationArgs

    applicationRestoreConfiguration Property Map
    The restore behavior of a restarting application.
    flinkRunConfiguration Property Map
    The starting parameters for a Flink-based Kinesis Data Analytics application.

    ApplicationApplicationConfigurationRunConfigurationApplicationRestoreConfiguration, ApplicationApplicationConfigurationRunConfigurationApplicationRestoreConfigurationArgs

    ApplicationRestoreType string
    Specifies how the application should be restored. Valid values: RESTORE_FROM_CUSTOM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, SKIP_RESTORE_FROM_SNAPSHOT.
    SnapshotName string
    The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for application_restore_type.
    ApplicationRestoreType string
    Specifies how the application should be restored. Valid values: RESTORE_FROM_CUSTOM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, SKIP_RESTORE_FROM_SNAPSHOT.
    SnapshotName string
    The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for application_restore_type.
    applicationRestoreType String
    Specifies how the application should be restored. Valid values: RESTORE_FROM_CUSTOM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, SKIP_RESTORE_FROM_SNAPSHOT.
    snapshotName String
    The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for application_restore_type.
    applicationRestoreType string
    Specifies how the application should be restored. Valid values: RESTORE_FROM_CUSTOM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, SKIP_RESTORE_FROM_SNAPSHOT.
    snapshotName string
    The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for application_restore_type.
    application_restore_type str
    Specifies how the application should be restored. Valid values: RESTORE_FROM_CUSTOM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, SKIP_RESTORE_FROM_SNAPSHOT.
    snapshot_name str
    The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for application_restore_type.
    applicationRestoreType String
    Specifies how the application should be restored. Valid values: RESTORE_FROM_CUSTOM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, SKIP_RESTORE_FROM_SNAPSHOT.
    snapshotName String
    The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for application_restore_type.

    ApplicationApplicationConfigurationRunConfigurationFlinkRunConfiguration, ApplicationApplicationConfigurationRunConfigurationFlinkRunConfigurationArgs

    AllowNonRestoredState bool
    When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. Default is false.
    AllowNonRestoredState bool
    When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. Default is false.
    allowNonRestoredState Boolean
    When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. Default is false.
    allowNonRestoredState boolean
    When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. Default is false.
    allow_non_restored_state bool
    When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. Default is false.
    allowNonRestoredState Boolean
    When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. Default is false.

    ApplicationApplicationConfigurationSqlApplicationConfiguration, ApplicationApplicationConfigurationSqlApplicationConfigurationArgs

    input Property Map
    The input stream used by the application.
    outputs List<Property Map>
    The destination streams used by the application.
    referenceDataSource Property Map
    The reference data source used by the application.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInput, ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs

    InputSchema ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
    NamePrefix string
    The name prefix to use when creating an in-application stream.
    InAppStreamNames List<string>
    InputId string
    InputParallelism ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelism
    Describes the number of in-application streams to create.
    InputProcessingConfiguration ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfiguration
    The input processing configuration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes.
    InputStartingPositionConfigurations List<ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfiguration>
    The point at which the application starts processing records from the streaming source.
    KinesisFirehoseInput ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInput
    If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
    KinesisStreamsInput ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInput
    If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
    InputSchema ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
    NamePrefix string
    The name prefix to use when creating an in-application stream.
    InAppStreamNames []string
    InputId string
    InputParallelism ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelism
    Describes the number of in-application streams to create.
    InputProcessingConfiguration ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfiguration
    The input processing configuration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes.
    InputStartingPositionConfigurations []ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfiguration
    The point at which the application starts processing records from the streaming source.
    KinesisFirehoseInput ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInput
    If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
    KinesisStreamsInput ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInput
    If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
    inputSchema ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
    namePrefix String
    The name prefix to use when creating an in-application stream.
    inAppStreamNames List<String>
    inputId String
    inputParallelism ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelism
    Describes the number of in-application streams to create.
    inputProcessingConfiguration ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfiguration
    The input processing configuration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes.
    inputStartingPositionConfigurations List<ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfiguration>
    The point at which the application starts processing records from the streaming source.
    kinesisFirehoseInput ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInput
    If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
    kinesisStreamsInput ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInput
    If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
    inputSchema ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
    namePrefix string
    The name prefix to use when creating an in-application stream.
    inAppStreamNames string[]
    inputId string
    inputParallelism ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelism
    Describes the number of in-application streams to create.
    inputProcessingConfiguration ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfiguration
    The input processing configuration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes.
    inputStartingPositionConfigurations ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfiguration[]
    The point at which the application starts processing records from the streaming source.
    kinesisFirehoseInput ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInput
    If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
    kinesisStreamsInput ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInput
    If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
    input_schema ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
    name_prefix str
    The name prefix to use when creating an in-application stream.
    in_app_stream_names Sequence[str]
    input_id str
    input_parallelism ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelism
    Describes the number of in-application streams to create.
    input_processing_configuration ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfiguration
    The input processing configuration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes.
    input_starting_position_configurations Sequence[ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfiguration]
    The point at which the application starts processing records from the streaming source.
    kinesis_firehose_input ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInput
    If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
    kinesis_streams_input ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInput
    If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
    inputSchema Property Map
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
    namePrefix String
    The name prefix to use when creating an in-application stream.
    inAppStreamNames List<String>
    inputId String
    inputParallelism Property Map
    Describes the number of in-application streams to create.
    inputProcessingConfiguration Property Map
    The input processing configuration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes.
    inputStartingPositionConfigurations List<Property Map>
    The point at which the application starts processing records from the streaming source.
    kinesisFirehoseInput Property Map
    If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
    kinesisStreamsInput Property Map
    If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelism, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs

    Count int
    The number of in-application streams to create.
    Count int
    The number of in-application streams to create.
    count Integer
    The number of in-application streams to create.
    count number
    The number of in-application streams to create.
    count int
    The number of in-application streams to create.
    count Number
    The number of in-application streams to create.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfiguration, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationArgs

    InputLambdaProcessor ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessor
    Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
    InputLambdaProcessor ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessor
    Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
    inputLambdaProcessor ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessor
    Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
    inputLambdaProcessor ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessor
    Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
    input_lambda_processor ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessor
    Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
    inputLambdaProcessor Property Map
    Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessor, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessorArgs

    ResourceArn string
    The ARN of the Lambda function that operates on records in the stream.
    ResourceArn string
    The ARN of the Lambda function that operates on records in the stream.
    resourceArn String
    The ARN of the Lambda function that operates on records in the stream.
    resourceArn string
    The ARN of the Lambda function that operates on records in the stream.
    resource_arn str
    The ARN of the Lambda function that operates on records in the stream.
    resourceArn String
    The ARN of the Lambda function that operates on records in the stream.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchema, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs

    RecordColumns List<ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumn>
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    RecordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    RecordEncoding string
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    RecordColumns []ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumn
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    RecordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    RecordEncoding string
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    recordColumns List<ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumn>
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    recordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    recordEncoding String
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    recordColumns ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumn[]
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    recordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    recordEncoding string
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    record_columns Sequence[ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumn]
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    record_format ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    record_encoding str
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    recordColumns List<Property Map>
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    recordFormat Property Map
    Specifies the format of the records on the streaming source.
    recordEncoding String
    Specifies the encoding of the records in the streaming source. For example, UTF-8.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumn, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs

    Name string
    The name of the column that is created in the in-application input stream or reference table.
    SqlType string
    The type of column created in the in-application input stream or reference table.
    Mapping string
    A reference to the data element in the streaming input or the reference data source.
    Name string
    The name of the column that is created in the in-application input stream or reference table.
    SqlType string
    The type of column created in the in-application input stream or reference table.
    Mapping string
    A reference to the data element in the streaming input or the reference data source.
    name String
    The name of the column that is created in the in-application input stream or reference table.
    sqlType String
    The type of column created in the in-application input stream or reference table.
    mapping String
    A reference to the data element in the streaming input or the reference data source.
    name string
    The name of the column that is created in the in-application input stream or reference table.
    sqlType string
    The type of column created in the in-application input stream or reference table.
    mapping string
    A reference to the data element in the streaming input or the reference data source.
    name str
    The name of the column that is created in the in-application input stream or reference table.
    sql_type str
    The type of column created in the in-application input stream or reference table.
    mapping str
    A reference to the data element in the streaming input or the reference data source.
    name String
    The name of the column that is created in the in-application input stream or reference table.
    sqlType String
    The type of column created in the in-application input stream or reference table.
    mapping String
    A reference to the data element in the streaming input or the reference data source.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormat, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs

    MappingParameters ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    RecordFormatType string
    The type of record format. Valid values: CSV, JSON.
    MappingParameters ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    RecordFormatType string
    The type of record format. Valid values: CSV, JSON.
    mappingParameters ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    recordFormatType String
    The type of record format. Valid values: CSV, JSON.
    mappingParameters ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    recordFormatType string
    The type of record format. Valid values: CSV, JSON.
    mapping_parameters ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    record_format_type str
    The type of record format. Valid values: CSV, JSON.
    mappingParameters Property Map
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    recordFormatType String
    The type of record format. Valid values: CSV, JSON.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParameters, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs

    csvMappingParameters Property Map
    Provides additional mapping information when the record format uses delimiters (for example, CSV).
    jsonMappingParameters Property Map
    Provides additional mapping information when JSON is the record format on the streaming source.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParameters, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs

    RecordColumnDelimiter string
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    RecordRowDelimiter string
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    RecordColumnDelimiter string
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    RecordRowDelimiter string
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    recordColumnDelimiter String
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    recordRowDelimiter String
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    recordColumnDelimiter string
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    recordRowDelimiter string
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    record_column_delimiter str
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    record_row_delimiter str
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    recordColumnDelimiter String
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    recordRowDelimiter String
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersJsonMappingParameters, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersJsonMappingParametersArgs

    RecordRowPath string
    The path to the top-level parent that contains the records.
    RecordRowPath string
    The path to the top-level parent that contains the records.
    recordRowPath String
    The path to the top-level parent that contains the records.
    recordRowPath string
    The path to the top-level parent that contains the records.
    record_row_path str
    The path to the top-level parent that contains the records.
    recordRowPath String
    The path to the top-level parent that contains the records.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfiguration, ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfigurationArgs

    InputStartingPosition string
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    InputStartingPosition string
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    inputStartingPosition String
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    inputStartingPosition string
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    input_starting_position str
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
    inputStartingPosition String
    The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInput, ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInputArgs

    ResourceArn string
    The ARN of the delivery stream.
    ResourceArn string
    The ARN of the delivery stream.
    resourceArn String
    The ARN of the delivery stream.
    resourceArn string
    The ARN of the delivery stream.
    resource_arn str
    The ARN of the delivery stream.
    resourceArn String
    The ARN of the delivery stream.

    ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInput, ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs

    ResourceArn string
    The ARN of the input Kinesis data stream to read.
    ResourceArn string
    The ARN of the input Kinesis data stream to read.
    resourceArn String
    The ARN of the input Kinesis data stream to read.
    resourceArn string
    The ARN of the input Kinesis data stream to read.
    resource_arn str
    The ARN of the input Kinesis data stream to read.
    resourceArn String
    The ARN of the input Kinesis data stream to read.

    ApplicationApplicationConfigurationSqlApplicationConfigurationOutput, ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs

    DestinationSchema ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchema
    Describes the data format when records are written to the destination.
    Name string
    The name of the in-application stream.
    KinesisFirehoseOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutput
    Identifies a Kinesis Data Firehose delivery stream as the destination.
    KinesisStreamsOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutput
    Identifies a Kinesis data stream as the destination.
    LambdaOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutput
    Identifies a Lambda function as the destination.
    OutputId string
    DestinationSchema ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchema
    Describes the data format when records are written to the destination.
    Name string
    The name of the in-application stream.
    KinesisFirehoseOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutput
    Identifies a Kinesis Data Firehose delivery stream as the destination.
    KinesisStreamsOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutput
    Identifies a Kinesis data stream as the destination.
    LambdaOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutput
    Identifies a Lambda function as the destination.
    OutputId string
    destinationSchema ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchema
    Describes the data format when records are written to the destination.
    name String
    The name of the in-application stream.
    kinesisFirehoseOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutput
    Identifies a Kinesis Data Firehose delivery stream as the destination.
    kinesisStreamsOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutput
    Identifies a Kinesis data stream as the destination.
    lambdaOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutput
    Identifies a Lambda function as the destination.
    outputId String
    destinationSchema ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchema
    Describes the data format when records are written to the destination.
    name string
    The name of the in-application stream.
    kinesisFirehoseOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutput
    Identifies a Kinesis Data Firehose delivery stream as the destination.
    kinesisStreamsOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutput
    Identifies a Kinesis data stream as the destination.
    lambdaOutput ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutput
    Identifies a Lambda function as the destination.
    outputId string
    destination_schema ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchema
    Describes the data format when records are written to the destination.
    name str
    The name of the in-application stream.
    kinesis_firehose_output ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutput
    Identifies a Kinesis Data Firehose delivery stream as the destination.
    kinesis_streams_output ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutput
    Identifies a Kinesis data stream as the destination.
    lambda_output ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutput
    Identifies a Lambda function as the destination.
    output_id str
    destinationSchema Property Map
    Describes the data format when records are written to the destination.
    name String
    The name of the in-application stream.
    kinesisFirehoseOutput Property Map
    Identifies a Kinesis Data Firehose delivery stream as the destination.
    kinesisStreamsOutput Property Map
    Identifies a Kinesis data stream as the destination.
    lambdaOutput Property Map
    Identifies a Lambda function as the destination.
    outputId String

    ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchema, ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs

    RecordFormatType string
    Specifies the format of the records on the output stream. Valid values: CSV, JSON.
    RecordFormatType string
    Specifies the format of the records on the output stream. Valid values: CSV, JSON.
    recordFormatType String
    Specifies the format of the records on the output stream. Valid values: CSV, JSON.
    recordFormatType string
    Specifies the format of the records on the output stream. Valid values: CSV, JSON.
    record_format_type str
    Specifies the format of the records on the output stream. Valid values: CSV, JSON.
    recordFormatType String
    Specifies the format of the records on the output stream. Valid values: CSV, JSON.

    ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutput, ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs

    ResourceArn string
    The ARN of the destination delivery stream to write to.
    ResourceArn string
    The ARN of the destination delivery stream to write to.
    resourceArn String
    The ARN of the destination delivery stream to write to.
    resourceArn string
    The ARN of the destination delivery stream to write to.
    resource_arn str
    The ARN of the destination delivery stream to write to.
    resourceArn String
    The ARN of the destination delivery stream to write to.

    ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutput, ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutputArgs

    ResourceArn string
    The ARN of the destination Kinesis data stream to write to.
    ResourceArn string
    The ARN of the destination Kinesis data stream to write to.
    resourceArn String
    The ARN of the destination Kinesis data stream to write to.
    resourceArn string
    The ARN of the destination Kinesis data stream to write to.
    resource_arn str
    The ARN of the destination Kinesis data stream to write to.
    resourceArn String
    The ARN of the destination Kinesis data stream to write to.

    ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutput, ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs

    ResourceArn string
    The ARN of the destination Lambda function to write to.
    ResourceArn string
    The ARN of the destination Lambda function to write to.
    resourceArn String
    The ARN of the destination Lambda function to write to.
    resourceArn string
    The ARN of the destination Lambda function to write to.
    resource_arn str
    The ARN of the destination Lambda function to write to.
    resourceArn String
    The ARN of the destination Lambda function to write to.

    ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSource, ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs

    ReferenceSchema ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
    S3ReferenceDataSource ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSource
    Identifies the S3 bucket and object that contains the reference data.
    TableName string
    The name of the in-application table to create.
    ReferenceId string
    ReferenceSchema ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
    S3ReferenceDataSource ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSource
    Identifies the S3 bucket and object that contains the reference data.
    TableName string
    The name of the in-application table to create.
    ReferenceId string
    referenceSchema ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
    s3ReferenceDataSource ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSource
    Identifies the S3 bucket and object that contains the reference data.
    tableName String
    The name of the in-application table to create.
    referenceId String
    referenceSchema ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
    s3ReferenceDataSource ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSource
    Identifies the S3 bucket and object that contains the reference data.
    tableName string
    The name of the in-application table to create.
    referenceId string
    reference_schema ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchema
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
    s3_reference_data_source ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSource
    Identifies the S3 bucket and object that contains the reference data.
    table_name str
    The name of the in-application table to create.
    reference_id str
    referenceSchema Property Map
    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
    s3ReferenceDataSource Property Map
    Identifies the S3 bucket and object that contains the reference data.
    tableName String
    The name of the in-application table to create.
    referenceId String

    ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchema, ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs

    RecordColumns List<ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn>
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    RecordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    RecordEncoding string
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    RecordColumns []ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    RecordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    RecordEncoding string
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    recordColumns List<ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn>
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    recordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    recordEncoding String
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    recordColumns ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn[]
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    recordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    recordEncoding string
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    record_columns Sequence[ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn]
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    record_format ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat
    Specifies the format of the records on the streaming source.
    record_encoding str
    Specifies the encoding of the records in the streaming source. For example, UTF-8.
    recordColumns List<Property Map>
    Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
    recordFormat Property Map
    Specifies the format of the records on the streaming source.
    recordEncoding String
    Specifies the encoding of the records in the streaming source. For example, UTF-8.

    ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn, ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs

    Name string
    The name of the column that is created in the in-application input stream or reference table.
    SqlType string
    The type of column created in the in-application input stream or reference table.
    Mapping string
    A reference to the data element in the streaming input or the reference data source.
    Name string
    The name of the column that is created in the in-application input stream or reference table.
    SqlType string
    The type of column created in the in-application input stream or reference table.
    Mapping string
    A reference to the data element in the streaming input or the reference data source.
    name String
    The name of the column that is created in the in-application input stream or reference table.
    sqlType String
    The type of column created in the in-application input stream or reference table.
    mapping String
    A reference to the data element in the streaming input or the reference data source.
    name string
    The name of the column that is created in the in-application input stream or reference table.
    sqlType string
    The type of column created in the in-application input stream or reference table.
    mapping string
    A reference to the data element in the streaming input or the reference data source.
    name str
    The name of the column that is created in the in-application input stream or reference table.
    sql_type str
    The type of column created in the in-application input stream or reference table.
    mapping str
    A reference to the data element in the streaming input or the reference data source.
    name String
    The name of the column that is created in the in-application input stream or reference table.
    sqlType String
    The type of column created in the in-application input stream or reference table.
    mapping String
    A reference to the data element in the streaming input or the reference data source.

    ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat, ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs

    MappingParameters ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    RecordFormatType string
    The type of record format. Valid values: CSV, JSON.
    MappingParameters ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    RecordFormatType string
    The type of record format. Valid values: CSV, JSON.
    mappingParameters ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    recordFormatType String
    The type of record format. Valid values: CSV, JSON.
    mappingParameters ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    recordFormatType string
    The type of record format. Valid values: CSV, JSON.
    mapping_parameters ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParameters
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    record_format_type str
    The type of record format. Valid values: CSV, JSON.
    mappingParameters Property Map
    Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    recordFormatType String
    The type of record format. Valid values: CSV, JSON.

    ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParameters, ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs

    csvMappingParameters Property Map
    Provides additional mapping information when the record format uses delimiters (for example, CSV).
    jsonMappingParameters Property Map
    Provides additional mapping information when JSON is the record format on the streaming source.

    ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersCsvMappingParameters, ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersCsvMappingParametersArgs

    RecordColumnDelimiter string
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    RecordRowDelimiter string
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    RecordColumnDelimiter string
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    RecordRowDelimiter string
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    recordColumnDelimiter String
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    recordRowDelimiter String
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    recordColumnDelimiter string
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    recordRowDelimiter string
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    record_column_delimiter str
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    record_row_delimiter str
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
    recordColumnDelimiter String
    The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
    recordRowDelimiter String
    The row delimiter. For example, in a CSV format, \n is the typical row delimiter.

    ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParameters, ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs

    RecordRowPath string
    The path to the top-level parent that contains the records.
    RecordRowPath string
    The path to the top-level parent that contains the records.
    recordRowPath String
    The path to the top-level parent that contains the records.
    recordRowPath string
    The path to the top-level parent that contains the records.
    record_row_path str
    The path to the top-level parent that contains the records.
    recordRowPath String
    The path to the top-level parent that contains the records.

    ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSource, ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs

    BucketArn string
    The ARN of the S3 bucket.
    FileKey string
    The object key name containing the reference data.
    BucketArn string
    The ARN of the S3 bucket.
    FileKey string
    The object key name containing the reference data.
    bucketArn String
    The ARN of the S3 bucket.
    fileKey String
    The object key name containing the reference data.
    bucketArn string
    The ARN of the S3 bucket.
    fileKey string
    The object key name containing the reference data.
    bucket_arn str
    The ARN of the S3 bucket.
    file_key str
    The object key name containing the reference data.
    bucketArn String
    The ARN of the S3 bucket.
    fileKey String
    The object key name containing the reference data.

    ApplicationApplicationConfigurationVpcConfiguration, ApplicationApplicationConfigurationVpcConfigurationArgs

    SecurityGroupIds List<string>
    The Security Group IDs used by the VPC configuration.
    SubnetIds List<string>
    The Subnet IDs used by the VPC configuration.
    VpcConfigurationId string
    VpcId string
    SecurityGroupIds []string
    The Security Group IDs used by the VPC configuration.
    SubnetIds []string
    The Subnet IDs used by the VPC configuration.
    VpcConfigurationId string
    VpcId string
    securityGroupIds List<String>
    The Security Group IDs used by the VPC configuration.
    subnetIds List<String>
    The Subnet IDs used by the VPC configuration.
    vpcConfigurationId String
    vpcId String
    securityGroupIds string[]
    The Security Group IDs used by the VPC configuration.
    subnetIds string[]
    The Subnet IDs used by the VPC configuration.
    vpcConfigurationId string
    vpcId string
    security_group_ids Sequence[str]
    The Security Group IDs used by the VPC configuration.
    subnet_ids Sequence[str]
    The Subnet IDs used by the VPC configuration.
    vpc_configuration_id str
    vpc_id str
    securityGroupIds List<String>
    The Security Group IDs used by the VPC configuration.
    subnetIds List<String>
    The Subnet IDs used by the VPC configuration.
    vpcConfigurationId String
    vpcId String

    ApplicationCloudwatchLoggingOptions, ApplicationCloudwatchLoggingOptionsArgs

    LogStreamArn string
    The ARN of the CloudWatch log stream to receive application messages.
    CloudwatchLoggingOptionId string
    LogStreamArn string
    The ARN of the CloudWatch log stream to receive application messages.
    CloudwatchLoggingOptionId string
    logStreamArn String
    The ARN of the CloudWatch log stream to receive application messages.
    cloudwatchLoggingOptionId String
    logStreamArn string
    The ARN of the CloudWatch log stream to receive application messages.
    cloudwatchLoggingOptionId string
    log_stream_arn str
    The ARN of the CloudWatch log stream to receive application messages.
    cloudwatch_logging_option_id str
    logStreamArn String
    The ARN of the CloudWatch log stream to receive application messages.
    cloudwatchLoggingOptionId String

    Import

    Using pulumi import, import aws_kinesisanalyticsv2_application using the application ARN. For example:

    $ pulumi import aws:kinesisanalyticsv2/application:Application example arn:aws:kinesisanalytics:us-west-2:123456789012:application/example-sql-application
    

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    AWS Classic pulumi/pulumi-aws
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the aws Terraform Provider.
    aws logo

    Try AWS Native preview for resources not in the classic version.

    AWS Classic v6.40.0 published on Wednesday, Jun 12, 2024 by Pulumi