AWS Classic

Pulumi Official
Package maintained by Pulumi
v5.10.0 published on Monday, Jul 11, 2022 by Pulumi

Application

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

Example Usage

using Pulumi;
using Aws = Pulumi.Aws;

class MyStack : Stack
{
    public MyStack()
    {
        var exampleBucketV2 = new Aws.S3.BucketV2("exampleBucketV2", new Aws.S3.BucketV2Args
        {
        });
        var exampleBucketObjectv2 = new Aws.S3.BucketObjectv2("exampleBucketObjectv2", new Aws.S3.BucketObjectv2Args
        {
            Bucket = exampleBucketV2.Bucket,
            Key = "example-flink-application",
            Source = new FileAsset("flink-app.jar"),
        });
        var exampleApplication = new Aws.KinesisAnalyticsV2.Application("exampleApplication", new Aws.KinesisAnalyticsV2.ApplicationArgs
        {
            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 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/v5/go/aws/kinesisanalyticsv2"
	"github.com/pulumi/pulumi-aws/sdk/v5/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.Bucket,
			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 java.util.*;
import java.io.*;
import java.nio.*;
import com.pulumi.*;

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.bucket())
            .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.bucket,
    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.bucket,
    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.bucket}
      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 Pulumi;
using Aws = Pulumi.Aws;

class MyStack : Stack
{
    public MyStack()
    {
        var exampleLogGroup = new Aws.CloudWatch.LogGroup("exampleLogGroup", new Aws.CloudWatch.LogGroupArgs
        {
        });
        var exampleLogStream = new Aws.CloudWatch.LogStream("exampleLogStream", new Aws.CloudWatch.LogStreamArgs
        {
            LogGroupName = exampleLogGroup.Name,
        });
        var exampleApplication = new Aws.KinesisAnalyticsV2.Application("exampleApplication", new Aws.KinesisAnalyticsV2.ApplicationArgs
        {
            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 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 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 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/v5/go/aws/cloudwatch"
	"github.com/pulumi/pulumi-aws/sdk/v5/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.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs{
						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.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArray{
						kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs{
							Name: pulumi.String("OUTPUT_1"),
							DestinationSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs{
								RecordFormatType: pulumi.String("JSON"),
							},
							LambdaOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs{
								ResourceArn: pulumi.Any(aws_lambda_function.Example.Arn),
							},
						},
						kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs{
							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 java.util.*;
import java.io.*;
import java.nio.*;
import com.pulumi.*;

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 Pulumi;
using Aws = Pulumi.Aws;

class MyStack : Stack
{
    public MyStack()
    {
        var exampleBucketV2 = new Aws.S3.BucketV2("exampleBucketV2", new Aws.S3.BucketV2Args
        {
        });
        var exampleBucketObjectv2 = new Aws.S3.BucketObjectv2("exampleBucketObjectv2", new Aws.S3.BucketObjectv2Args
        {
            Bucket = exampleBucketV2.Bucket,
            Key = "example-flink-application",
            Source = new FileAsset("flink-app.jar"),
        });
        var exampleApplication = new Aws.KinesisAnalyticsV2.Application("exampleApplication", new Aws.KinesisAnalyticsV2.ApplicationArgs
        {
            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 = 
                    {
                        aws_security_group.Example[0].Id,
                        aws_security_group.Example[1].Id,
                    },
                    SubnetIds = 
                    {
                        aws_subnet.Example.Id,
                    },
                },
            },
        });
    }

}
package main

import (
	"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/kinesisanalyticsv2"
	"github.com/pulumi/pulumi-aws/sdk/v5/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.Bucket,
			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{
						pulumi.Any(aws_security_group.Example[0].Id),
						pulumi.Any(aws_security_group.Example[1].Id),
					},
					SubnetIds: pulumi.StringArray{
						pulumi.Any(aws_subnet.Example.Id),
					},
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}
package generated_program;

import java.util.*;
import java.io.*;
import java.nio.*;
import com.pulumi.*;

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.bucket())
            .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.bucket,
    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.bucket,
    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.bucket}
      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 a 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.

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

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.

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

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

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.

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.

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.

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.

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.

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.

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.

versionId Number

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

Look up an 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 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.

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.

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.

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.

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

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.

versionId Integer

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

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.

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.

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.

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.

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.

versionId Number

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

Supporting Types

ApplicationApplicationConfiguration

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

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

S3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

Information about the Amazon S3 bucket containing the application code.

TextContent string

The text-format code for the application.

S3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

Information about the Amazon S3 bucket containing the application code.

TextContent string

The text-format code for the application.

s3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

Information about the Amazon S3 bucket containing the application code.

textContent String

The text-format code for the application.

s3ContentLocation ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

Information about the Amazon S3 bucket containing the application code.

textContent string

The text-format code for the application.

s3_content_location ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

Information about the Amazon S3 bucket containing the application code.

text_content str

The text-format code for the application.

s3ContentLocation Property Map

Information about the Amazon S3 bucket containing the application code.

textContent String

The text-format code for the application.

ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation

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

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

propertyGroups List<Property Map>

Describes the execution property groups.

ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroup

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

RecordColumns List<ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn>

Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

RecordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat

Specifies the format of the records on the streaming source.

RecordEncoding string

Specifies the encoding of the records in the streaming source. For example, UTF-8.

RecordColumns []ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn

Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

RecordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat

Specifies the format of the records on the streaming source.

RecordEncoding string

Specifies the encoding of the records in the streaming source. For example, UTF-8.

recordColumns List<ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn>

Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

recordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat

Specifies the format of the records on the streaming source.

recordEncoding String

Specifies the encoding of the records in the streaming source. For example, UTF-8.

recordColumns ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn[]

Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

recordFormat ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat

Specifies the format of the records on the streaming source.

recordEncoding string

Specifies the encoding of the records in the streaming source. For example, UTF-8.

record_columns Sequence[ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn]

Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

record_format ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat

Specifies the format of the records on the streaming source.

record_encoding str

Specifies the encoding of the records in the streaming source. For example, UTF-8.

recordColumns List<Property Map>

Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

recordFormat Property Map

Specifies the format of the records on the streaming source.

recordEncoding String

Specifies the encoding of the records in the streaming source. For example, UTF-8.

ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn

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

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

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

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

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

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

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

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

aws_kinesisanalyticsv2_application can be imported by using the application ARN, e.g.,

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

Package Details

Repository
https://github.com/pulumi/pulumi-aws
License
Apache-2.0
Notes

This Pulumi package is based on the aws Terraform Provider.