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.4.0 published on Tuesday, Oct 3, 2023 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.4.0 published on Tuesday, Oct 3, 2023 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

    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using Aws = Pulumi.Aws;
    
    return await Deployment.RunAsync(() => 
    {
        var exampleBucketV2 = new Aws.S3.BucketV2("exampleBucketV2");
    
        var exampleBucketObjectv2 = new Aws.S3.BucketObjectv2("exampleBucketObjectv2", new()
        {
            Bucket = exampleBucketV2.Id,
            Key = "example-flink-application",
            Source = new FileAsset("flink-app.jar"),
        });
    
        var exampleApplication = new Aws.KinesisAnalyticsV2.Application("exampleApplication", new()
        {
            RuntimeEnvironment = "FLINK-1_8",
            ServiceExecutionRole = aws_iam_role.Example.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 = exampleBucketV2.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 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 {
    		exampleBucketV2, err := s3.NewBucketV2(ctx, "exampleBucketV2", nil)
    		if err != nil {
    			return err
    		}
    		exampleBucketObjectv2, err := s3.NewBucketObjectv2(ctx, "exampleBucketObjectv2", &s3.BucketObjectv2Args{
    			Bucket: exampleBucketV2.ID(),
    			Key:    pulumi.String("example-flink-application"),
    			Source: pulumi.NewFileAsset("flink-app.jar"),
    		})
    		if err != nil {
    			return err
    		}
    		_, err = kinesisanalyticsv2.NewApplication(ctx, "exampleApplication", &kinesisanalyticsv2.ApplicationArgs{
    			RuntimeEnvironment:   pulumi.String("FLINK-1_8"),
    			ServiceExecutionRole: pulumi.Any(aws_iam_role.Example.Arn),
    			ApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationArgs{
    				ApplicationCodeConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs{
    					CodeContent: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs{
    						S3ContentLocation: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs{
    							BucketArn: exampleBucketV2.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
    	})
    }
    
    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.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 exampleBucketV2 = new BucketV2("exampleBucketV2");
    
            var exampleBucketObjectv2 = new BucketObjectv2("exampleBucketObjectv2", BucketObjectv2Args.builder()        
                .bucket(exampleBucketV2.id())
                .key("example-flink-application")
                .source(new FileAsset("flink-app.jar"))
                .build());
    
            var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()        
                .runtimeEnvironment("FLINK-1_8")
                .serviceExecutionRole(aws_iam_role.example().arn())
                .applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
                    .applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
                        .codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
                            .s3ContentLocation(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs.builder()
                                .bucketArn(exampleBucketV2.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());
    
        }
    }
    
    import pulumi
    import pulumi_aws as aws
    
    example_bucket_v2 = aws.s3.BucketV2("exampleBucketV2")
    example_bucket_objectv2 = aws.s3.BucketObjectv2("exampleBucketObjectv2",
        bucket=example_bucket_v2.id,
        key="example-flink-application",
        source=pulumi.FileAsset("flink-app.jar"))
    example_application = aws.kinesisanalyticsv2.Application("exampleApplication",
        runtime_environment="FLINK-1_8",
        service_execution_role=aws_iam_role["example"]["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_bucket_v2.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",
        })
    
    import * as pulumi from "@pulumi/pulumi";
    import * as aws from "@pulumi/aws";
    
    const exampleBucketV2 = new aws.s3.BucketV2("exampleBucketV2", {});
    const exampleBucketObjectv2 = new aws.s3.BucketObjectv2("exampleBucketObjectv2", {
        bucket: exampleBucketV2.id,
        key: "example-flink-application",
        source: new pulumi.asset.FileAsset("flink-app.jar"),
    });
    const exampleApplication = new aws.kinesisanalyticsv2.Application("exampleApplication", {
        runtimeEnvironment: "FLINK-1_8",
        serviceExecutionRole: aws_iam_role.example.arn,
        applicationConfiguration: {
            applicationCodeConfiguration: {
                codeContent: {
                    s3ContentLocation: {
                        bucketArn: exampleBucketV2.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",
        },
    });
    
    resources:
      exampleBucketV2:
        type: aws:s3:BucketV2
      exampleBucketObjectv2:
        type: aws:s3:BucketObjectv2
        properties:
          bucket: ${exampleBucketV2.id}
          key: example-flink-application
          source:
            fn::FileAsset: flink-app.jar
      exampleApplication:
        type: aws:kinesisanalyticsv2:Application
        properties:
          runtimeEnvironment: FLINK-1_8
          serviceExecutionRole: ${aws_iam_role.example.arn}
          applicationConfiguration:
            applicationCodeConfiguration:
              codeContent:
                s3ContentLocation:
                  bucketArn: ${exampleBucketV2.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

    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using Aws = Pulumi.Aws;
    
    return await Deployment.RunAsync(() => 
    {
        var exampleLogGroup = new Aws.CloudWatch.LogGroup("exampleLogGroup");
    
        var exampleLogStream = new Aws.CloudWatch.LogStream("exampleLogStream", new()
        {
            LogGroupName = exampleLogGroup.Name,
        });
    
        var exampleApplication = new Aws.KinesisAnalyticsV2.Application("exampleApplication", new()
        {
            RuntimeEnvironment = "SQL-1_0",
            ServiceExecutionRole = aws_iam_role.Example.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 = aws_kinesis_stream.Example.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 = aws_lambda_function.Example.Arn,
                            },
                        },
                        new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs
                        {
                            Name = "OUTPUT_2",
                            DestinationSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs
                            {
                                RecordFormatType = "CSV",
                            },
                            KinesisFirehoseOutput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs
                            {
                                ResourceArn = aws_kinesis_firehose_delivery_stream.Example.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 = aws_s3_bucket.Example.Arn,
                            FileKey = "KEY-1",
                        },
                    },
                },
            },
            CloudwatchLoggingOptions = new Aws.KinesisAnalyticsV2.Inputs.ApplicationCloudwatchLoggingOptionsArgs
            {
                LogStreamArn = exampleLogStream.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 {
    		exampleLogGroup, err := cloudwatch.NewLogGroup(ctx, "exampleLogGroup", nil)
    		if err != nil {
    			return err
    		}
    		exampleLogStream, err := cloudwatch.NewLogStream(ctx, "exampleLogStream", &cloudwatch.LogStreamArgs{
    			LogGroupName: exampleLogGroup.Name,
    		})
    		if err != nil {
    			return err
    		}
    		_, err = kinesisanalyticsv2.NewApplication(ctx, "exampleApplication", &kinesisanalyticsv2.ApplicationArgs{
    			RuntimeEnvironment:   pulumi.String("SQL-1_0"),
    			ServiceExecutionRole: pulumi.Any(aws_iam_role.Example.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(aws_kinesis_stream.Example.Arn),
    						},
    					},
    					Outputs: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArray{
    						&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArgs{
    							Name: pulumi.String("OUTPUT_1"),
    							DestinationSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs{
    								RecordFormatType: pulumi.String("JSON"),
    							},
    							LambdaOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs{
    								ResourceArn: pulumi.Any(aws_lambda_function.Example.Arn),
    							},
    						},
    						&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArgs{
    							Name: pulumi.String("OUTPUT_2"),
    							DestinationSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs{
    								RecordFormatType: pulumi.String("CSV"),
    							},
    							KinesisFirehoseOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs{
    								ResourceArn: pulumi.Any(aws_kinesis_firehose_delivery_stream.Example.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(aws_s3_bucket.Example.Arn),
    							FileKey:   pulumi.String("KEY-1"),
    						},
    					},
    				},
    			},
    			CloudwatchLoggingOptions: &kinesisanalyticsv2.ApplicationCloudwatchLoggingOptionsArgs{
    				LogStreamArn: exampleLogStream.Arn,
    			},
    		})
    		if err != nil {
    			return err
    		}
    		return nil
    	})
    }
    
    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.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 exampleLogGroup = new LogGroup("exampleLogGroup");
    
            var exampleLogStream = new LogStream("exampleLogStream", LogStreamArgs.builder()        
                .logGroupName(exampleLogGroup.name())
                .build());
    
            var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()        
                .runtimeEnvironment("SQL-1_0")
                .serviceExecutionRole(aws_iam_role.example().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(aws_kinesis_stream.example().arn())
                                .build())
                            .build())
                        .outputs(                    
                            ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs.builder()
                                .name("OUTPUT_1")
                                .destinationSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs.builder()
                                    .recordFormatType("JSON")
                                    .build())
                                .lambdaOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs.builder()
                                    .resourceArn(aws_lambda_function.example().arn())
                                    .build())
                                .build(),
                            ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs.builder()
                                .name("OUTPUT_2")
                                .destinationSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs.builder()
                                    .recordFormatType("CSV")
                                    .build())
                                .kinesisFirehoseOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs.builder()
                                    .resourceArn(aws_kinesis_firehose_delivery_stream.example().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(aws_s3_bucket.example().arn())
                                .fileKey("KEY-1")
                                .build())
                            .build())
                        .build())
                    .build())
                .cloudwatchLoggingOptions(ApplicationCloudwatchLoggingOptionsArgs.builder()
                    .logStreamArn(exampleLogStream.arn())
                    .build())
                .build());
    
        }
    }
    
    import pulumi
    import pulumi_aws as aws
    
    example_log_group = aws.cloudwatch.LogGroup("exampleLogGroup")
    example_log_stream = aws.cloudwatch.LogStream("exampleLogStream", log_group_name=example_log_group.name)
    example_application = aws.kinesisanalyticsv2.Application("exampleApplication",
        runtime_environment="SQL-1_0",
        service_execution_role=aws_iam_role["example"]["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=aws_kinesis_stream["example"]["arn"],
                    ),
                ),
                outputs=[
                    aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs(
                        name="OUTPUT_1",
                        destination_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs(
                            record_format_type="JSON",
                        ),
                        lambda_output=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs(
                            resource_arn=aws_lambda_function["example"]["arn"],
                        ),
                    ),
                    aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs(
                        name="OUTPUT_2",
                        destination_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs(
                            record_format_type="CSV",
                        ),
                        kinesis_firehose_output=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs(
                            resource_arn=aws_kinesis_firehose_delivery_stream["example"]["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=aws_s3_bucket["example"]["arn"],
                        file_key="KEY-1",
                    ),
                ),
            ),
        ),
        cloudwatch_logging_options=aws.kinesisanalyticsv2.ApplicationCloudwatchLoggingOptionsArgs(
            log_stream_arn=example_log_stream.arn,
        ))
    
    import * as pulumi from "@pulumi/pulumi";
    import * as aws from "@pulumi/aws";
    
    const exampleLogGroup = new aws.cloudwatch.LogGroup("exampleLogGroup", {});
    const exampleLogStream = new aws.cloudwatch.LogStream("exampleLogStream", {logGroupName: exampleLogGroup.name});
    const exampleApplication = new aws.kinesisanalyticsv2.Application("exampleApplication", {
        runtimeEnvironment: "SQL-1_0",
        serviceExecutionRole: aws_iam_role.example.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: aws_kinesis_stream.example.arn,
                    },
                },
                outputs: [
                    {
                        name: "OUTPUT_1",
                        destinationSchema: {
                            recordFormatType: "JSON",
                        },
                        lambdaOutput: {
                            resourceArn: aws_lambda_function.example.arn,
                        },
                    },
                    {
                        name: "OUTPUT_2",
                        destinationSchema: {
                            recordFormatType: "CSV",
                        },
                        kinesisFirehoseOutput: {
                            resourceArn: aws_kinesis_firehose_delivery_stream.example.arn,
                        },
                    },
                ],
                referenceDataSource: {
                    tableName: "TABLE-1",
                    referenceSchema: {
                        recordColumns: [{
                            name: "COLUMN_1",
                            sqlType: "INTEGER",
                        }],
                        recordFormat: {
                            recordFormatType: "JSON",
                            mappingParameters: {
                                jsonMappingParameters: {
                                    recordRowPath: "$",
                                },
                            },
                        },
                    },
                    s3ReferenceDataSource: {
                        bucketArn: aws_s3_bucket.example.arn,
                        fileKey: "KEY-1",
                    },
                },
            },
        },
        cloudwatchLoggingOptions: {
            logStreamArn: exampleLogStream.arn,
        },
    });
    
    resources:
      exampleLogGroup:
        type: aws:cloudwatch:LogGroup
      exampleLogStream:
        type: aws:cloudwatch:LogStream
        properties:
          logGroupName: ${exampleLogGroup.name}
      exampleApplication:
        type: aws:kinesisanalyticsv2:Application
        properties:
          runtimeEnvironment: SQL-1_0
          serviceExecutionRole: ${aws_iam_role.example.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: ${aws_kinesis_stream.example.arn}
              outputs:
                - name: OUTPUT_1
                  destinationSchema:
                    recordFormatType: JSON
                  lambdaOutput:
                    resourceArn: ${aws_lambda_function.example.arn}
                - name: OUTPUT_2
                  destinationSchema:
                    recordFormatType: CSV
                  kinesisFirehoseOutput:
                    resourceArn: ${aws_kinesis_firehose_delivery_stream.example.arn}
              referenceDataSource:
                tableName: TABLE-1
                referenceSchema:
                  recordColumns:
                    - name: COLUMN_1
                      sqlType: INTEGER
                  recordFormat:
                    recordFormatType: JSON
                    mappingParameters:
                      jsonMappingParameters:
                        recordRowPath: $
                s3ReferenceDataSource:
                  bucketArn: ${aws_s3_bucket.example.arn}
                  fileKey: KEY-1
          cloudwatchLoggingOptions:
            logStreamArn: ${exampleLogStream.arn}
    

    VPC Configuration

    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using Aws = Pulumi.Aws;
    
    return await Deployment.RunAsync(() => 
    {
        var exampleBucketV2 = new Aws.S3.BucketV2("exampleBucketV2");
    
        var exampleBucketObjectv2 = new Aws.S3.BucketObjectv2("exampleBucketObjectv2", new()
        {
            Bucket = exampleBucketV2.Id,
            Key = "example-flink-application",
            Source = new FileAsset("flink-app.jar"),
        });
    
        var exampleApplication = new Aws.KinesisAnalyticsV2.Application("exampleApplication", new()
        {
            RuntimeEnvironment = "FLINK-1_8",
            ServiceExecutionRole = aws_iam_role.Example.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 = exampleBucketV2.Arn,
                            FileKey = exampleBucketObjectv2.Key,
                        },
                    },
                    CodeContentType = "ZIPFILE",
                },
                VpcConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationVpcConfigurationArgs
                {
                    SecurityGroupIds = new[]
                    {
                        aws_security_group.Example[0].Id,
                        aws_security_group.Example[1].Id,
                    },
                    SubnetIds = new[]
                    {
                        aws_subnet.Example.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 {
    		exampleBucketV2, err := s3.NewBucketV2(ctx, "exampleBucketV2", nil)
    		if err != nil {
    			return err
    		}
    		exampleBucketObjectv2, err := s3.NewBucketObjectv2(ctx, "exampleBucketObjectv2", &s3.BucketObjectv2Args{
    			Bucket: exampleBucketV2.ID(),
    			Key:    pulumi.String("example-flink-application"),
    			Source: pulumi.NewFileAsset("flink-app.jar"),
    		})
    		if err != nil {
    			return err
    		}
    		_, err = kinesisanalyticsv2.NewApplication(ctx, "exampleApplication", &kinesisanalyticsv2.ApplicationArgs{
    			RuntimeEnvironment:   pulumi.String("FLINK-1_8"),
    			ServiceExecutionRole: pulumi.Any(aws_iam_role.Example.Arn),
    			ApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationArgs{
    				ApplicationCodeConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs{
    					CodeContent: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs{
    						S3ContentLocation: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs{
    							BucketArn: exampleBucketV2.Arn,
    							FileKey:   exampleBucketObjectv2.Key,
    						},
    					},
    					CodeContentType: pulumi.String("ZIPFILE"),
    				},
    				VpcConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationVpcConfigurationArgs{
    					SecurityGroupIds: pulumi.StringArray{
    						aws_security_group.Example[0].Id,
    						aws_security_group.Example[1].Id,
    					},
    					SubnetIds: pulumi.StringArray{
    						aws_subnet.Example.Id,
    					},
    				},
    			},
    		})
    		if err != nil {
    			return err
    		}
    		return nil
    	})
    }
    
    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.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 exampleBucketV2 = new BucketV2("exampleBucketV2");
    
            var exampleBucketObjectv2 = new BucketObjectv2("exampleBucketObjectv2", BucketObjectv2Args.builder()        
                .bucket(exampleBucketV2.id())
                .key("example-flink-application")
                .source(new FileAsset("flink-app.jar"))
                .build());
    
            var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()        
                .runtimeEnvironment("FLINK-1_8")
                .serviceExecutionRole(aws_iam_role.example().arn())
                .applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
                    .applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
                        .codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
                            .s3ContentLocation(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs.builder()
                                .bucketArn(exampleBucketV2.arn())
                                .fileKey(exampleBucketObjectv2.key())
                                .build())
                            .build())
                        .codeContentType("ZIPFILE")
                        .build())
                    .vpcConfiguration(ApplicationApplicationConfigurationVpcConfigurationArgs.builder()
                        .securityGroupIds(                    
                            aws_security_group.example()[0].id(),
                            aws_security_group.example()[1].id())
                        .subnetIds(aws_subnet.example().id())
                        .build())
                    .build())
                .build());
    
        }
    }
    
    import pulumi
    import pulumi_aws as aws
    
    example_bucket_v2 = aws.s3.BucketV2("exampleBucketV2")
    example_bucket_objectv2 = aws.s3.BucketObjectv2("exampleBucketObjectv2",
        bucket=example_bucket_v2.id,
        key="example-flink-application",
        source=pulumi.FileAsset("flink-app.jar"))
    example_application = aws.kinesisanalyticsv2.Application("exampleApplication",
        runtime_environment="FLINK-1_8",
        service_execution_role=aws_iam_role["example"]["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_bucket_v2.arn,
                        file_key=example_bucket_objectv2.key,
                    ),
                ),
                code_content_type="ZIPFILE",
            ),
            vpc_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationVpcConfigurationArgs(
                security_group_ids=[
                    aws_security_group["example"][0]["id"],
                    aws_security_group["example"][1]["id"],
                ],
                subnet_ids=[aws_subnet["example"]["id"]],
            ),
        ))
    
    import * as pulumi from "@pulumi/pulumi";
    import * as aws from "@pulumi/aws";
    
    const exampleBucketV2 = new aws.s3.BucketV2("exampleBucketV2", {});
    const exampleBucketObjectv2 = new aws.s3.BucketObjectv2("exampleBucketObjectv2", {
        bucket: exampleBucketV2.id,
        key: "example-flink-application",
        source: new pulumi.asset.FileAsset("flink-app.jar"),
    });
    const exampleApplication = new aws.kinesisanalyticsv2.Application("exampleApplication", {
        runtimeEnvironment: "FLINK-1_8",
        serviceExecutionRole: aws_iam_role.example.arn,
        applicationConfiguration: {
            applicationCodeConfiguration: {
                codeContent: {
                    s3ContentLocation: {
                        bucketArn: exampleBucketV2.arn,
                        fileKey: exampleBucketObjectv2.key,
                    },
                },
                codeContentType: "ZIPFILE",
            },
            vpcConfiguration: {
                securityGroupIds: [
                    aws_security_group.example[0].id,
                    aws_security_group.example[1].id,
                ],
                subnetIds: [aws_subnet.example.id],
            },
        },
    });
    
    resources:
      exampleBucketV2:
        type: aws:s3:BucketV2
      exampleBucketObjectv2:
        type: aws:s3:BucketObjectv2
        properties:
          bucket: ${exampleBucketV2.id}
          key: example-flink-application
          source:
            fn::FileAsset: flink-app.jar
      exampleApplication:
        type: aws:kinesisanalyticsv2:Application
        properties:
          runtimeEnvironment: FLINK-1_8
          serviceExecutionRole: ${aws_iam_role.example.arn}
          applicationConfiguration:
            applicationCodeConfiguration:
              codeContent:
                s3ContentLocation:
                  bucketArn: ${exampleBucketV2.arn}
                  fileKey: ${exampleBucketObjectv2.key}
              codeContentType: ZIPFILE
            vpcConfiguration:
              securityGroupIds:
                - ${aws_security_group.example[0].id}
                - ${aws_security_group.example[1].id}
              subnetIds:
                - ${aws_subnet.example.id}
    

    Create Application Resource

    new Application(name: string, args: ApplicationArgs, opts?: CustomResourceOptions);
    @overload
    def Application(resource_name: str,
                    opts: Optional[ResourceOptions] = None,
                    application_configuration: Optional[ApplicationApplicationConfigurationArgs] = None,
                    cloudwatch_logging_options: Optional[ApplicationCloudwatchLoggingOptionsArgs] = None,
                    description: Optional[str] = None,
                    force_stop: Optional[bool] = None,
                    name: Optional[str] = None,
                    runtime_environment: Optional[str] = None,
                    service_execution_role: Optional[str] = None,
                    start_application: Optional[bool] = None,
                    tags: Optional[Mapping[str, str]] = None)
    @overload
    def Application(resource_name: str,
                    args: ApplicationArgs,
                    opts: Optional[ResourceOptions] = 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.
    
    
    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.

    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.

    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

    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.

    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

    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.

    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

    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.

    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

    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.

    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

    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.

    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

    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,
            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

    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.

    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

    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.

    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

    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.

    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

    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.

    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

    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.

    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

    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.

    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.

    The s3_content_location object supports the following:

    S3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

    Information about the Amazon S3 bucket containing the application code.

    TextContent string

    The text-format code for the application.

    The s3_content_location object supports the following:

    s3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

    Information about the Amazon S3 bucket containing the application code.

    textContent String

    The text-format code for the application.

    The s3_content_location object supports the following:

    s3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

    Information about the Amazon S3 bucket containing the application code.

    textContent string

    The text-format code for the application.

    The s3_content_location object supports the following:

    s3_content_location ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

    Information about the Amazon S3 bucket containing the application code.

    text_content str

    The text-format code for the application.

    The s3_content_location object supports the following:

    s3ContentLocation Property Map

    Information about the Amazon S3 bucket containing the application code.

    textContent String

    The text-format code for the application.

    The s3_content_location object supports the following:

    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.

    The s3_reference_data_source object supports the following:

    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.

    The s3_reference_data_source object supports the following:

    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.

    The s3_reference_data_source object supports the following:

    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.

    The s3_reference_data_source object supports the following:

    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.

    The s3_reference_data_source object supports the following:

    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.

    The s3_reference_data_source object supports the following:

    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 for the S3 bucket containing the application code.

    FileKey string

    The file key for 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.

    bucketArn String

    The ARN for the S3 bucket containing the application code.

    fileKey String

    The file key for 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.

    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.

    bucketArn String

    The ARN for the S3 bucket containing the application code.

    fileKey String

    The file key for the object containing the application code.

    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
    

    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.4.0 published on Tuesday, Oct 3, 2023 by Pulumi