aws.kinesis.AnalyticsApplication

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";

const testStream = new aws.kinesis.Stream("test_stream", {
    streamModeDetails: {
        streamMode: "ON_DEMAND",
    },
    name: "pulumi-kinesis-test",
});
const testApplication = new aws.kinesis.AnalyticsApplication("test_application", {
    inputs: {
        kinesisStream: {
            resourceArn: testStream.arn,
            roleArn: test.arn,
        },
        parallelism: {
            count: 1,
        },
        schema: {
            recordFormat: {
                mappingParameters: {
                    json: {
                        recordRowPath: "$",
                    },
                },
            },
            recordColumns: [{
                mapping: "$.test",
                name: "test",
                sqlType: "VARCHAR(8)",
            }],
            recordEncoding: "UTF-8",
        },
        namePrefix: "test_prefix",
    },
    name: "kinesis-analytics-application-test",
});

import pulumi
import pulumi_aws as aws

test_stream = aws.kinesis.Stream("test_stream",
    stream_mode_details={
        "stream_mode": "ON_DEMAND",
    },
    name="pulumi-kinesis-test")
test_application = aws.kinesis.AnalyticsApplication("test_application",
    inputs={
        "kinesis_stream": {
            "resource_arn": test_stream.arn,
            "role_arn": test["arn"],
        },
        "parallelism": {
            "count": 1,
        },
        "schema": {
            "record_format": {
                "mapping_parameters": {
                    "json": {
                        "record_row_path": "$",
                    },
                },
            },
            "record_columns": [{
                "mapping": "$.test",
                "name": "test",
                "sql_type": "VARCHAR(8)",
            }],
            "record_encoding": "UTF-8",
        },
        "name_prefix": "test_prefix",
    },
    name="kinesis-analytics-application-test")

package main

import (
	"github.com/pulumi/pulumi-aws/sdk/v7/go/aws/kinesis"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		testStream, err := kinesis.NewStream(ctx, "test_stream", &kinesis.StreamArgs{
			StreamModeDetails: &kinesis.StreamStreamModeDetailsArgs{
				StreamMode: pulumi.String("ON_DEMAND"),
			},
			Name: pulumi.String("pulumi-kinesis-test"),
		})
		if err != nil {
			return err
		}
		_, err = kinesis.NewAnalyticsApplication(ctx, "test_application", &kinesis.AnalyticsApplicationArgs{
			Inputs: &kinesis.AnalyticsApplicationInputsArgs{
				KinesisStream: &kinesis.AnalyticsApplicationInputsKinesisStreamArgs{
					ResourceArn: testStream.Arn,
					RoleArn:     pulumi.Any(test.Arn),
				},
				Parallelism: &kinesis.AnalyticsApplicationInputsParallelismArgs{
					Count: pulumi.Int(1),
				},
				Schema: &kinesis.AnalyticsApplicationInputsSchemaArgs{
					RecordFormat: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatArgs{
						MappingParameters: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs{
							Json: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs{
								RecordRowPath: pulumi.String("$"),
							},
						},
					},
					RecordColumns: kinesis.AnalyticsApplicationInputsSchemaRecordColumnArray{
						&kinesis.AnalyticsApplicationInputsSchemaRecordColumnArgs{
							Mapping: pulumi.String("$.test"),
							Name:    pulumi.String("test"),
							SqlType: pulumi.String("VARCHAR(8)"),
						},
					},
					RecordEncoding: pulumi.String("UTF-8"),
				},
				NamePrefix: pulumi.String("test_prefix"),
			},
			Name: pulumi.String("kinesis-analytics-application-test"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;

return await Deployment.RunAsync(() => 
{
    var testStream = new Aws.Kinesis.Stream("test_stream", new()
    {
        StreamModeDetails = new Aws.Kinesis.Inputs.StreamStreamModeDetailsArgs
        {
            StreamMode = "ON_DEMAND",
        },
        Name = "pulumi-kinesis-test",
    });

    var testApplication = new Aws.Kinesis.AnalyticsApplication("test_application", new()
    {
        Inputs = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsArgs
        {
            KinesisStream = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsKinesisStreamArgs
            {
                ResourceArn = testStream.Arn,
                RoleArn = test.Arn,
            },
            Parallelism = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsParallelismArgs
            {
                Count = 1,
            },
            Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaArgs
            {
                RecordFormat = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs
                {
                    MappingParameters = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs
                    {
                        Json = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs
                        {
                            RecordRowPath = "$",
                        },
                    },
                },
                RecordColumns = new[]
                {
                    new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordColumnArgs
                    {
                        Mapping = "$.test",
                        Name = "test",
                        SqlType = "VARCHAR(8)",
                    },
                },
                RecordEncoding = "UTF-8",
            },
            NamePrefix = "test_prefix",
        },
        Name = "kinesis-analytics-application-test",
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.kinesis.Stream;
import com.pulumi.aws.kinesis.StreamArgs;
import com.pulumi.aws.kinesis.inputs.StreamStreamModeDetailsArgs;
import com.pulumi.aws.kinesis.AnalyticsApplication;
import com.pulumi.aws.kinesis.AnalyticsApplicationArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsKinesisStreamArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsParallelismArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordColumnArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var testStream = new Stream("testStream", StreamArgs.builder()
            .streamModeDetails(StreamStreamModeDetailsArgs.builder()
                .streamMode("ON_DEMAND")
                .build())
            .name("pulumi-kinesis-test")
            .build());

        var testApplication = new AnalyticsApplication("testApplication", AnalyticsApplicationArgs.builder()
            .inputs(AnalyticsApplicationInputsArgs.builder()
                .kinesisStream(AnalyticsApplicationInputsKinesisStreamArgs.builder()
                    .resourceArn(testStream.arn())
                    .roleArn(test.get("arn"))
                    .build())
                .parallelism(AnalyticsApplicationInputsParallelismArgs.builder()
                    .count(1)
                    .build())
                .schema(AnalyticsApplicationInputsSchemaArgs.builder()
                    .recordFormat(AnalyticsApplicationInputsSchemaRecordFormatArgs.builder()
                        .mappingParameters(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs.builder()
                            .json(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs.builder()
                                .recordRowPath("$")
                                .build())
                            .build())
                        .build())
                    .recordColumns(AnalyticsApplicationInputsSchemaRecordColumnArgs.builder()
                        .mapping("$.test")
                        .name("test")
                        .sqlType("VARCHAR(8)")
                        .build())
                    .recordEncoding("UTF-8")
                    .build())
                .namePrefix("test_prefix")
                .build())
            .name("kinesis-analytics-application-test")
            .build());

    }
}

resources:
  testStream:
    type: aws:kinesis:Stream
    name: test_stream
    properties:
      streamModeDetails:
        streamMode: ON_DEMAND
      name: pulumi-kinesis-test
  testApplication:
    type: aws:kinesis:AnalyticsApplication
    name: test_application
    properties:
      inputs:
        kinesisStream:
          resourceArn: ${testStream.arn}
          roleArn: ${test.arn}
        parallelism:
          count: 1
        schema:
          recordFormat:
            mappingParameters:
              json:
                recordRowPath: $
          recordColumns:
            - mapping: $.test
              name: test
              sqlType: VARCHAR(8)
          recordEncoding: UTF-8
        namePrefix: test_prefix
      name: kinesis-analytics-application-test

terraform {
  required_providers {
    aws = {
      source = "pulumi/aws"
    }
  }
}

resource "aws_kinesis_stream" "test_stream" {
  lifecycle {
    create_before_destroy = true
  }
  stream_mode_details {
    stream_mode = "ON_DEMAND"
  }
  name = "pulumi-kinesis-test"
}
resource "aws_kinesis_analytics_application" "test_application" {
  lifecycle {
    create_before_destroy = true
  }
  inputs {
    kinesis_stream {
      resource_arn = aws_kinesis_stream.test_stream.arn
      role_arn     = test.arn
    }
    parallelism {
      count = 1
    }
    schema {
      record_format {
        mapping_parameters {
          json {
            record_row_path = "$"
          }
        }
      }
      record_columns {
        mapping  = "$.test"
        name     = "test"
        sql_type = "VARCHAR(8)"
      }
      record_encoding = "UTF-8"
    }
    name_prefix = "test_prefix"
  }
  name = "kinesis-analytics-application-test"
}

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";

const example = new aws.cloudwatch.LogGroup("example", {name: "analytics"});
const exampleLogStream = new aws.cloudwatch.LogStream("example", {
    name: "example-kinesis-application",
    logGroupName: example.name,
});
const exampleStream = new aws.kinesis.Stream("example", {
    streamModeDetails: {
        streamMode: "ON_DEMAND",
    },
    name: "example-kinesis-stream",
});
const exampleFirehoseDeliveryStream = new aws.kinesis.FirehoseDeliveryStream("example", {
    extendedS3Configuration: {
        bucketArn: exampleAwsS3Bucket.arn,
        roleArn: exampleAwsIamRole.arn,
    },
    name: "example-kinesis-delivery-stream",
    destination: "extended_s3",
});
const test = new aws.kinesis.AnalyticsApplication("test", {
    cloudwatchLoggingOptions: {
        logStreamArn: exampleLogStream.arn,
        roleArn: exampleAwsIamRole.arn,
    },
    inputs: {
        schema: {
            recordFormat: {
                mappingParameters: {
                    csv: {
                        recordColumnDelimiter: ",",
                        recordRowDelimiter: "|",
                    },
                },
            },
            recordColumns: [{
                name: "COLUMN_1",
                sqlType: "INTEGER",
            }],
        },
        kinesisStream: {
            resourceArn: exampleStream.arn,
            roleArn: exampleAwsIamRole.arn,
        },
        startingPositionConfigurations: [{
            startingPosition: "NOW",
        }],
        namePrefix: "example_prefix",
    },
    outputs: [{
        schema: {
            recordFormatType: "CSV",
        },
        kinesisFirehose: {
            resourceArn: exampleFirehoseDeliveryStream.arn,
            roleArn: exampleAwsIamRole.arn,
        },
        name: "OUTPUT_1",
    }],
    name: "example-application",
    startApplication: true,
});

import pulumi
import pulumi_aws as aws

example = aws.cloudwatch.LogGroup("example", name="analytics")
example_log_stream = aws.cloudwatch.LogStream("example",
    name="example-kinesis-application",
    log_group_name=example.name)
example_stream = aws.kinesis.Stream("example",
    stream_mode_details={
        "stream_mode": "ON_DEMAND",
    },
    name="example-kinesis-stream")
example_firehose_delivery_stream = aws.kinesis.FirehoseDeliveryStream("example",
    extended_s3_configuration={
        "bucket_arn": example_aws_s3_bucket["arn"],
        "role_arn": example_aws_iam_role["arn"],
    },
    name="example-kinesis-delivery-stream",
    destination="extended_s3")
test = aws.kinesis.AnalyticsApplication("test",
    cloudwatch_logging_options={
        "log_stream_arn": example_log_stream.arn,
        "role_arn": example_aws_iam_role["arn"],
    },
    inputs={
        "schema": {
            "record_format": {
                "mapping_parameters": {
                    "csv": {
                        "record_column_delimiter": ",",
                        "record_row_delimiter": "|",
                    },
                },
            },
            "record_columns": [{
                "name": "COLUMN_1",
                "sql_type": "INTEGER",
            }],
        },
        "kinesis_stream": {
            "resource_arn": example_stream.arn,
            "role_arn": example_aws_iam_role["arn"],
        },
        "starting_position_configurations": [{
            "starting_position": "NOW",
        }],
        "name_prefix": "example_prefix",
    },
    outputs=[{
        "schema": {
            "record_format_type": "CSV",
        },
        "kinesis_firehose": {
            "resource_arn": example_firehose_delivery_stream.arn,
            "role_arn": example_aws_iam_role["arn"],
        },
        "name": "OUTPUT_1",
    }],
    name="example-application",
    start_application=True)

package main

import (
	"github.com/pulumi/pulumi-aws/sdk/v7/go/aws/cloudwatch"
	"github.com/pulumi/pulumi-aws/sdk/v7/go/aws/kinesis"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := cloudwatch.NewLogGroup(ctx, "example", &cloudwatch.LogGroupArgs{
			Name: pulumi.String("analytics"),
		})
		if err != nil {
			return err
		}
		exampleLogStream, err := cloudwatch.NewLogStream(ctx, "example", &cloudwatch.LogStreamArgs{
			Name:         pulumi.String("example-kinesis-application"),
			LogGroupName: example.Name,
		})
		if err != nil {
			return err
		}
		exampleStream, err := kinesis.NewStream(ctx, "example", &kinesis.StreamArgs{
			StreamModeDetails: &kinesis.StreamStreamModeDetailsArgs{
				StreamMode: pulumi.String("ON_DEMAND"),
			},
			Name: pulumi.String("example-kinesis-stream"),
		})
		if err != nil {
			return err
		}
		exampleFirehoseDeliveryStream, err := kinesis.NewFirehoseDeliveryStream(ctx, "example", &kinesis.FirehoseDeliveryStreamArgs{
			ExtendedS3Configuration: &kinesis.FirehoseDeliveryStreamExtendedS3ConfigurationArgs{
				BucketArn: pulumi.Any(exampleAwsS3Bucket.Arn),
				RoleArn:   pulumi.Any(exampleAwsIamRole.Arn),
			},
			Name:        pulumi.String("example-kinesis-delivery-stream"),
			Destination: pulumi.String("extended_s3"),
		})
		if err != nil {
			return err
		}
		_, err = kinesis.NewAnalyticsApplication(ctx, "test", &kinesis.AnalyticsApplicationArgs{
			CloudwatchLoggingOptions: &kinesis.AnalyticsApplicationCloudwatchLoggingOptionsArgs{
				LogStreamArn: exampleLogStream.Arn,
				RoleArn:      pulumi.Any(exampleAwsIamRole.Arn),
			},
			Inputs: &kinesis.AnalyticsApplicationInputsArgs{
				Schema: &kinesis.AnalyticsApplicationInputsSchemaArgs{
					RecordFormat: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatArgs{
						MappingParameters: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs{
							Csv: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs{
								RecordColumnDelimiter: pulumi.String(","),
								RecordRowDelimiter:    pulumi.String("|"),
							},
						},
					},
					RecordColumns: kinesis.AnalyticsApplicationInputsSchemaRecordColumnArray{
						&kinesis.AnalyticsApplicationInputsSchemaRecordColumnArgs{
							Name:    pulumi.String("COLUMN_1"),
							SqlType: pulumi.String("INTEGER"),
						},
					},
				},
				KinesisStream: &kinesis.AnalyticsApplicationInputsKinesisStreamArgs{
					ResourceArn: exampleStream.Arn,
					RoleArn:     pulumi.Any(exampleAwsIamRole.Arn),
				},
				StartingPositionConfigurations: kinesis.AnalyticsApplicationInputsStartingPositionConfigurationArray{
					&kinesis.AnalyticsApplicationInputsStartingPositionConfigurationArgs{
						StartingPosition: pulumi.String("NOW"),
					},
				},
				NamePrefix: pulumi.String("example_prefix"),
			},
			Outputs: kinesis.AnalyticsApplicationOutputTypeArray{
				&kinesis.AnalyticsApplicationOutputTypeArgs{
					Schema: &kinesis.AnalyticsApplicationOutputSchemaArgs{
						RecordFormatType: pulumi.String("CSV"),
					},
					KinesisFirehose: &kinesis.AnalyticsApplicationOutputKinesisFirehoseArgs{
						ResourceArn: exampleFirehoseDeliveryStream.Arn,
						RoleArn:     pulumi.Any(exampleAwsIamRole.Arn),
					},
					Name: pulumi.String("OUTPUT_1"),
				},
			},
			Name:             pulumi.String("example-application"),
			StartApplication: pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;

return await Deployment.RunAsync(() => 
{
    var example = new Aws.CloudWatch.LogGroup("example", new()
    {
        Name = "analytics",
    });

    var exampleLogStream = new Aws.CloudWatch.LogStream("example", new()
    {
        Name = "example-kinesis-application",
        LogGroupName = example.Name,
    });

    var exampleStream = new Aws.Kinesis.Stream("example", new()
    {
        StreamModeDetails = new Aws.Kinesis.Inputs.StreamStreamModeDetailsArgs
        {
            StreamMode = "ON_DEMAND",
        },
        Name = "example-kinesis-stream",
    });

    var exampleFirehoseDeliveryStream = new Aws.Kinesis.FirehoseDeliveryStream("example", new()
    {
        ExtendedS3Configuration = new Aws.Kinesis.Inputs.FirehoseDeliveryStreamExtendedS3ConfigurationArgs
        {
            BucketArn = exampleAwsS3Bucket.Arn,
            RoleArn = exampleAwsIamRole.Arn,
        },
        Name = "example-kinesis-delivery-stream",
        Destination = "extended_s3",
    });

    var test = new Aws.Kinesis.AnalyticsApplication("test", new()
    {
        CloudwatchLoggingOptions = new Aws.Kinesis.Inputs.AnalyticsApplicationCloudwatchLoggingOptionsArgs
        {
            LogStreamArn = exampleLogStream.Arn,
            RoleArn = exampleAwsIamRole.Arn,
        },
        Inputs = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsArgs
        {
            Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaArgs
            {
                RecordFormat = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs
                {
                    MappingParameters = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs
                    {
                        Csv = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs
                        {
                            RecordColumnDelimiter = ",",
                            RecordRowDelimiter = "|",
                        },
                    },
                },
                RecordColumns = new[]
                {
                    new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordColumnArgs
                    {
                        Name = "COLUMN_1",
                        SqlType = "INTEGER",
                    },
                },
            },
            KinesisStream = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsKinesisStreamArgs
            {
                ResourceArn = exampleStream.Arn,
                RoleArn = exampleAwsIamRole.Arn,
            },
            StartingPositionConfigurations = new[]
            {
                new Aws.Kinesis.Inputs.AnalyticsApplicationInputsStartingPositionConfigurationArgs
                {
                    StartingPosition = "NOW",
                },
            },
            NamePrefix = "example_prefix",
        },
        Outputs = new[]
        {
            new Aws.Kinesis.Inputs.AnalyticsApplicationOutputArgs
            {
                Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputSchemaArgs
                {
                    RecordFormatType = "CSV",
                },
                KinesisFirehose = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputKinesisFirehoseArgs
                {
                    ResourceArn = exampleFirehoseDeliveryStream.Arn,
                    RoleArn = exampleAwsIamRole.Arn,
                },
                Name = "OUTPUT_1",
            },
        },
        Name = "example-application",
        StartApplication = true,
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.cloudwatch.LogGroup;
import com.pulumi.aws.cloudwatch.LogGroupArgs;
import com.pulumi.aws.cloudwatch.LogStream;
import com.pulumi.aws.cloudwatch.LogStreamArgs;
import com.pulumi.aws.kinesis.Stream;
import com.pulumi.aws.kinesis.StreamArgs;
import com.pulumi.aws.kinesis.inputs.StreamStreamModeDetailsArgs;
import com.pulumi.aws.kinesis.FirehoseDeliveryStream;
import com.pulumi.aws.kinesis.FirehoseDeliveryStreamArgs;
import com.pulumi.aws.kinesis.inputs.FirehoseDeliveryStreamExtendedS3ConfigurationArgs;
import com.pulumi.aws.kinesis.AnalyticsApplication;
import com.pulumi.aws.kinesis.AnalyticsApplicationArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationCloudwatchLoggingOptionsArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsSchemaRecordColumnArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsKinesisStreamArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationInputsStartingPositionConfigurationArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationOutputArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationOutputSchemaArgs;
import com.pulumi.aws.kinesis.inputs.AnalyticsApplicationOutputKinesisFirehoseArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var example = new LogGroup("example", LogGroupArgs.builder()
            .name("analytics")
            .build());

        var exampleLogStream = new LogStream("exampleLogStream", LogStreamArgs.builder()
            .name("example-kinesis-application")
            .logGroupName(example.name())
            .build());

        var exampleStream = new Stream("exampleStream", StreamArgs.builder()
            .streamModeDetails(StreamStreamModeDetailsArgs.builder()
                .streamMode("ON_DEMAND")
                .build())
            .name("example-kinesis-stream")
            .build());

        var exampleFirehoseDeliveryStream = new FirehoseDeliveryStream("exampleFirehoseDeliveryStream", FirehoseDeliveryStreamArgs.builder()
            .extendedS3Configuration(FirehoseDeliveryStreamExtendedS3ConfigurationArgs.builder()
                .bucketArn(exampleAwsS3Bucket.get("arn"))
                .roleArn(exampleAwsIamRole.get("arn"))
                .build())
            .name("example-kinesis-delivery-stream")
            .destination("extended_s3")
            .build());

        var test = new AnalyticsApplication("test", AnalyticsApplicationArgs.builder()
            .cloudwatchLoggingOptions(AnalyticsApplicationCloudwatchLoggingOptionsArgs.builder()
                .logStreamArn(exampleLogStream.arn())
                .roleArn(exampleAwsIamRole.get("arn"))
                .build())
            .inputs(AnalyticsApplicationInputsArgs.builder()
                .schema(AnalyticsApplicationInputsSchemaArgs.builder()
                    .recordFormat(AnalyticsApplicationInputsSchemaRecordFormatArgs.builder()
                        .mappingParameters(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs.builder()
                            .csv(AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs.builder()
                                .recordColumnDelimiter(",")
                                .recordRowDelimiter("|")
                                .build())
                            .build())
                        .build())
                    .recordColumns(AnalyticsApplicationInputsSchemaRecordColumnArgs.builder()
                        .name("COLUMN_1")
                        .sqlType("INTEGER")
                        .build())
                    .build())
                .kinesisStream(AnalyticsApplicationInputsKinesisStreamArgs.builder()
                    .resourceArn(exampleStream.arn())
                    .roleArn(exampleAwsIamRole.get("arn"))
                    .build())
                .startingPositionConfigurations(AnalyticsApplicationInputsStartingPositionConfigurationArgs.builder()
                    .startingPosition("NOW")
                    .build())
                .namePrefix("example_prefix")
                .build())
            .outputs(AnalyticsApplicationOutputArgs.builder()
                .schema(AnalyticsApplicationOutputSchemaArgs.builder()
                    .recordFormatType("CSV")
                    .build())
                .kinesisFirehose(AnalyticsApplicationOutputKinesisFirehoseArgs.builder()
                    .resourceArn(exampleFirehoseDeliveryStream.arn())
                    .roleArn(exampleAwsIamRole.get("arn"))
                    .build())
                .name("OUTPUT_1")
                .build())
            .name("example-application")
            .startApplication(true)
            .build());

    }
}

resources:
  example:
    type: aws:cloudwatch:LogGroup
    properties:
      name: analytics
  exampleLogStream:
    type: aws:cloudwatch:LogStream
    name: example
    properties:
      name: example-kinesis-application
      logGroupName: ${example.name}
  exampleStream:
    type: aws:kinesis:Stream
    name: example
    properties:
      streamModeDetails:
        streamMode: ON_DEMAND
      name: example-kinesis-stream
  exampleFirehoseDeliveryStream:
    type: aws:kinesis:FirehoseDeliveryStream
    name: example
    properties:
      extendedS3Configuration:
        bucketArn: ${exampleAwsS3Bucket.arn}
        roleArn: ${exampleAwsIamRole.arn}
      name: example-kinesis-delivery-stream
      destination: extended_s3
  test:
    type: aws:kinesis:AnalyticsApplication
    properties:
      cloudwatchLoggingOptions:
        logStreamArn: ${exampleLogStream.arn}
        roleArn: ${exampleAwsIamRole.arn}
      inputs:
        schema:
          recordFormat:
            mappingParameters:
              csv:
                recordColumnDelimiter: ','
                recordRowDelimiter: '|'
          recordColumns:
            - name: COLUMN_1
              sqlType: INTEGER
        kinesisStream:
          resourceArn: ${exampleStream.arn}
          roleArn: ${exampleAwsIamRole.arn}
        startingPositionConfigurations:
          - startingPosition: NOW
        namePrefix: example_prefix
      outputs:
        - schema:
            recordFormatType: CSV
          kinesisFirehose:
            resourceArn: ${exampleFirehoseDeliveryStream.arn}
            roleArn: ${exampleAwsIamRole.arn}
          name: OUTPUT_1
      name: example-application
      startApplication: true

terraform {
  required_providers {
    aws = {
      source = "pulumi/aws"
    }
  }
}

resource "aws_cloudwatch_log_group" "example" {
  lifecycle {
    create_before_destroy = true
  }
  name = "analytics"
}
resource "aws_cloudwatch_log_stream" "example" {
  lifecycle {
    create_before_destroy = true
  }
  name           = "example-kinesis-application"
  log_group_name = aws_cloudwatch_log_group.example.name
}
resource "aws_kinesis_stream" "example" {
  lifecycle {
    create_before_destroy = true
  }
  stream_mode_details {
    stream_mode = "ON_DEMAND"
  }
  name = "example-kinesis-stream"
}
resource "aws_kinesis_firehose_delivery_stream" "example" {
  lifecycle {
    create_before_destroy = true
  }
  extended_s3_configuration {
    bucket_arn = exampleAwsS3Bucket.arn
    role_arn   = exampleAwsIamRole.arn
  }
  name        = "example-kinesis-delivery-stream"
  destination = "extended_s3"
}
resource "aws_kinesis_analytics_application" "test" {
  lifecycle {
    create_before_destroy = true
  }
  cloudwatch_logging_options {
    log_stream_arn = aws_cloudwatch_log_stream.example.arn
    role_arn       = exampleAwsIamRole.arn
  }
  inputs {
    schema {
      record_format {
        mapping_parameters {
          csv {
            record_column_delimiter = ","
            record_row_delimiter    = "|"
          }
        }
      }
      record_columns {
        name     = "COLUMN_1"
        sql_type = "INTEGER"
      }
    }
    kinesis_stream {
      resource_arn = aws_kinesis_stream.example.arn
      role_arn     = exampleAwsIamRole.arn
    }
    starting_position_configuration {
      starting_position = "NOW"
    }
    name_prefix = "example_prefix"
  }
  outputs {
    schema {
      record_format_type = "CSV"
    }
    kinesis_firehose {
      resource_arn = aws_kinesis_firehose_delivery_stream.example.arn
      role_arn     = exampleAwsIamRole.arn
    }
    name = "OUTPUT_1"
  }
  name              = "example-application"
  start_application = true
}

var analyticsApplicationResource = new Aws.Kinesis.AnalyticsApplication("analyticsApplicationResource", new()
{
    CloudwatchLoggingOptions = new Aws.Kinesis.Inputs.AnalyticsApplicationCloudwatchLoggingOptionsArgs
    {
        LogStreamArn = "string",
        RoleArn = "string",
        Id = "string",
    },
    Code = "string",
    Description = "string",
    Inputs = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsArgs
    {
        NamePrefix = "string",
        Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaArgs
        {
            RecordColumns = new[]
            {
                new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordColumnArgs
                {
                    Name = "string",
                    SqlType = "string",
                    Mapping = "string",
                },
            },
            RecordFormat = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatArgs
            {
                MappingParameters = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs
                {
                    Csv = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs
                    {
                        RecordColumnDelimiter = "string",
                        RecordRowDelimiter = "string",
                    },
                    Json = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs
                    {
                        RecordRowPath = "string",
                    },
                },
                RecordFormatType = "string",
            },
            RecordEncoding = "string",
        },
        Id = "string",
        KinesisFirehose = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsKinesisFirehoseArgs
        {
            ResourceArn = "string",
            RoleArn = "string",
        },
        KinesisStream = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsKinesisStreamArgs
        {
            ResourceArn = "string",
            RoleArn = "string",
        },
        Parallelism = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsParallelismArgs
        {
            Count = 0,
        },
        ProcessingConfiguration = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsProcessingConfigurationArgs
        {
            Lambda = new Aws.Kinesis.Inputs.AnalyticsApplicationInputsProcessingConfigurationLambdaArgs
            {
                ResourceArn = "string",
                RoleArn = "string",
            },
        },
        StartingPositionConfigurations = new[]
        {
            new Aws.Kinesis.Inputs.AnalyticsApplicationInputsStartingPositionConfigurationArgs
            {
                StartingPosition = "string",
            },
        },
        StreamNames = new[]
        {
            "string",
        },
    },
    Name = "string",
    Outputs = new[]
    {
        new Aws.Kinesis.Inputs.AnalyticsApplicationOutputArgs
        {
            Name = "string",
            Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputSchemaArgs
            {
                RecordFormatType = "string",
            },
            Id = "string",
            KinesisFirehose = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputKinesisFirehoseArgs
            {
                ResourceArn = "string",
                RoleArn = "string",
            },
            KinesisStream = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputKinesisStreamArgs
            {
                ResourceArn = "string",
                RoleArn = "string",
            },
            Lambda = new Aws.Kinesis.Inputs.AnalyticsApplicationOutputLambdaArgs
            {
                ResourceArn = "string",
                RoleArn = "string",
            },
        },
    },
    ReferenceDataSources = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesArgs
    {
        S3 = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesS3Args
        {
            BucketArn = "string",
            FileKey = "string",
            RoleArn = "string",
        },
        Schema = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaArgs
        {
            RecordColumns = new[]
            {
                new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordColumnArgs
                {
                    Name = "string",
                    SqlType = "string",
                    Mapping = "string",
                },
            },
            RecordFormat = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatArgs
            {
                MappingParameters = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersArgs
                {
                    Csv = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsvArgs
                    {
                        RecordColumnDelimiter = "string",
                        RecordRowDelimiter = "string",
                    },
                    Json = new Aws.Kinesis.Inputs.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJsonArgs
                    {
                        RecordRowPath = "string",
                    },
                },
                RecordFormatType = "string",
            },
            RecordEncoding = "string",
        },
        TableName = "string",
        Id = "string",
    },
    Region = "string",
    StartApplication = false,
    Tags = 
    {
        { "string", "string" },
    },
});

example, err := kinesis.NewAnalyticsApplication(ctx, "analyticsApplicationResource", &kinesis.AnalyticsApplicationArgs{
	CloudwatchLoggingOptions: &kinesis.AnalyticsApplicationCloudwatchLoggingOptionsArgs{
		LogStreamArn: pulumi.String("string"),
		RoleArn:      pulumi.String("string"),
		Id:           pulumi.String("string"),
	},
	Code:        pulumi.String("string"),
	Description: pulumi.String("string"),
	Inputs: &kinesis.AnalyticsApplicationInputsArgs{
		NamePrefix: pulumi.String("string"),
		Schema: &kinesis.AnalyticsApplicationInputsSchemaArgs{
			RecordColumns: kinesis.AnalyticsApplicationInputsSchemaRecordColumnArray{
				&kinesis.AnalyticsApplicationInputsSchemaRecordColumnArgs{
					Name:    pulumi.String("string"),
					SqlType: pulumi.String("string"),
					Mapping: pulumi.String("string"),
				},
			},
			RecordFormat: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatArgs{
				MappingParameters: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersArgs{
					Csv: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersCsvArgs{
						RecordColumnDelimiter: pulumi.String("string"),
						RecordRowDelimiter:    pulumi.String("string"),
					},
					Json: &kinesis.AnalyticsApplicationInputsSchemaRecordFormatMappingParametersJsonArgs{
						RecordRowPath: pulumi.String("string"),
					},
				},
				RecordFormatType: pulumi.String("string"),
			},
			RecordEncoding: pulumi.String("string"),
		},
		Id: pulumi.String("string"),
		KinesisFirehose: &kinesis.AnalyticsApplicationInputsKinesisFirehoseArgs{
			ResourceArn: pulumi.String("string"),
			RoleArn:     pulumi.String("string"),
		},
		KinesisStream: &kinesis.AnalyticsApplicationInputsKinesisStreamArgs{
			ResourceArn: pulumi.String("string"),
			RoleArn:     pulumi.String("string"),
		},
		Parallelism: &kinesis.AnalyticsApplicationInputsParallelismArgs{
			Count: pulumi.Int(0),
		},
		ProcessingConfiguration: &kinesis.AnalyticsApplicationInputsProcessingConfigurationArgs{
			Lambda: &kinesis.AnalyticsApplicationInputsProcessingConfigurationLambdaArgs{
				ResourceArn: pulumi.String("string"),
				RoleArn:     pulumi.String("string"),
			},
		},
		StartingPositionConfigurations: kinesis.AnalyticsApplicationInputsStartingPositionConfigurationArray{
			&kinesis.AnalyticsApplicationInputsStartingPositionConfigurationArgs{
				StartingPosition: pulumi.String("string"),
			},
		},
		StreamNames: pulumi.StringArray{
			pulumi.String("string"),
		},
	},
	Name: pulumi.String("string"),
	Outputs: kinesis.AnalyticsApplicationOutputTypeArray{
		&kinesis.AnalyticsApplicationOutputTypeArgs{
			Name: pulumi.String("string"),
			Schema: &kinesis.AnalyticsApplicationOutputSchemaArgs{
				RecordFormatType: pulumi.String("string"),
			},
			Id: pulumi.String("string"),
			KinesisFirehose: &kinesis.AnalyticsApplicationOutputKinesisFirehoseArgs{
				ResourceArn: pulumi.String("string"),
				RoleArn:     pulumi.String("string"),
			},
			KinesisStream: &kinesis.AnalyticsApplicationOutputKinesisStreamArgs{
				ResourceArn: pulumi.String("string"),
				RoleArn:     pulumi.String("string"),
			},
			Lambda: &kinesis.AnalyticsApplicationOutputLambdaArgs{
				ResourceArn: pulumi.String("string"),
				RoleArn:     pulumi.String("string"),
			},
		},
	},
	ReferenceDataSources: &kinesis.AnalyticsApplicationReferenceDataSourcesArgs{
		S3: &kinesis.AnalyticsApplicationReferenceDataSourcesS3Args{
			BucketArn: pulumi.String("string"),
			FileKey:   pulumi.String("string"),
			RoleArn:   pulumi.String("string"),
		},
		Schema: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaArgs{
			RecordColumns: kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordColumnArray{
				&kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordColumnArgs{
					Name:    pulumi.String("string"),
					SqlType: pulumi.String("string"),
					Mapping: pulumi.String("string"),
				},
			},
			RecordFormat: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatArgs{
				MappingParameters: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersArgs{
					Csv: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersCsvArgs{
						RecordColumnDelimiter: pulumi.String("string"),
						RecordRowDelimiter:    pulumi.String("string"),
					},
					Json: &kinesis.AnalyticsApplicationReferenceDataSourcesSchemaRecordFormatMappingParametersJsonArgs{
						RecordRowPath: pulumi.String("string"),
					},
				},
				RecordFormatType: pulumi.String("string"),
			},
			RecordEncoding: pulumi.String("string"),
		},
		TableName: pulumi.String("string"),
		Id:        pulumi.String("string"),
	},
	Region:           pulumi.String("string"),
	StartApplication: pulumi.Bool(false),
	Tags: pulumi.StringMap{
		"string": pulumi.String("string"),
	},
})