Docs
Packages
AWS Classic v5.41.0, May 15 23
AWS Classic v5.41.0, May 15 23
aws.kinesisanalyticsv2.Application
Explore with Pulumi AI
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
Apache Flink Application
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
var exampleBucketV2 = new Aws.S3.BucketV2("exampleBucketV2");
var exampleBucketObjectv2 = new Aws.S3.BucketObjectv2("exampleBucketObjectv2", new()
{
Bucket = exampleBucketV2.Id,
Key = "example-flink-application",
Source = new FileAsset("flink-app.jar"),
});
var exampleApplication = new Aws.KinesisAnalyticsV2.Application("exampleApplication", new()
{
RuntimeEnvironment = "FLINK-1_8",
ServiceExecutionRole = aws_iam_role.Example.Arn,
ApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationArgs
{
ApplicationCodeConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs
{
CodeContent = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs
{
S3ContentLocation = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs
{
BucketArn = exampleBucketV2.Arn,
FileKey = exampleBucketObjectv2.Key,
},
},
CodeContentType = "ZIPFILE",
},
EnvironmentProperties = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationEnvironmentPropertiesArgs
{
PropertyGroups = new[]
{
new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs
{
PropertyGroupId = "PROPERTY-GROUP-1",
PropertyMap =
{
{ "Key1", "Value1" },
},
},
new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs
{
PropertyGroupId = "PROPERTY-GROUP-2",
PropertyMap =
{
{ "KeyA", "ValueA" },
{ "KeyB", "ValueB" },
},
},
},
},
FlinkApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs
{
CheckpointConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs
{
ConfigurationType = "DEFAULT",
},
MonitoringConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs
{
ConfigurationType = "CUSTOM",
LogLevel = "DEBUG",
MetricsLevel = "TASK",
},
ParallelismConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs
{
AutoScalingEnabled = true,
ConfigurationType = "CUSTOM",
Parallelism = 10,
ParallelismPerKpu = 4,
},
},
},
Tags =
{
{ "Environment", "test" },
},
});
});
package main
import (
"github.com/pulumi/pulumi-aws/sdk/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.ID(),
Key: pulumi.String("example-flink-application"),
Source: pulumi.NewFileAsset("flink-app.jar"),
})
if err != nil {
return err
}
_, err = kinesisanalyticsv2.NewApplication(ctx, "exampleApplication", &kinesisanalyticsv2.ApplicationArgs{
RuntimeEnvironment: pulumi.String("FLINK-1_8"),
ServiceExecutionRole: pulumi.Any(aws_iam_role.Example.Arn),
ApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationArgs{
ApplicationCodeConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs{
CodeContent: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs{
S3ContentLocation: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs{
BucketArn: exampleBucketV2.Arn,
FileKey: exampleBucketObjectv2.Key,
},
},
CodeContentType: pulumi.String("ZIPFILE"),
},
EnvironmentProperties: &kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesArgs{
PropertyGroups: kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArray{
&kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs{
PropertyGroupId: pulumi.String("PROPERTY-GROUP-1"),
PropertyMap: pulumi.StringMap{
"Key1": pulumi.String("Value1"),
},
},
&kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs{
PropertyGroupId: pulumi.String("PROPERTY-GROUP-2"),
PropertyMap: pulumi.StringMap{
"KeyA": pulumi.String("ValueA"),
"KeyB": pulumi.String("ValueB"),
},
},
},
},
FlinkApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs{
CheckpointConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs{
ConfigurationType: pulumi.String("DEFAULT"),
},
MonitoringConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs{
ConfigurationType: pulumi.String("CUSTOM"),
LogLevel: pulumi.String("DEBUG"),
MetricsLevel: pulumi.String("TASK"),
},
ParallelismConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs{
AutoScalingEnabled: pulumi.Bool(true),
ConfigurationType: pulumi.String("CUSTOM"),
Parallelism: pulumi.Int(10),
ParallelismPerKpu: pulumi.Int(4),
},
},
},
Tags: pulumi.StringMap{
"Environment": pulumi.String("test"),
},
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.s3.BucketV2;
import com.pulumi.aws.s3.BucketObjectv2;
import com.pulumi.aws.s3.BucketObjectv2Args;
import com.pulumi.aws.kinesisanalyticsv2.Application;
import com.pulumi.aws.kinesisanalyticsv2.ApplicationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationEnvironmentPropertiesArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs;
import com.pulumi.asset.FileAsset;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var exampleBucketV2 = new BucketV2("exampleBucketV2");
var exampleBucketObjectv2 = new BucketObjectv2("exampleBucketObjectv2", BucketObjectv2Args.builder()
.bucket(exampleBucketV2.id())
.key("example-flink-application")
.source(new FileAsset("flink-app.jar"))
.build());
var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()
.runtimeEnvironment("FLINK-1_8")
.serviceExecutionRole(aws_iam_role.example().arn())
.applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
.applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
.codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
.s3ContentLocation(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs.builder()
.bucketArn(exampleBucketV2.arn())
.fileKey(exampleBucketObjectv2.key())
.build())
.build())
.codeContentType("ZIPFILE")
.build())
.environmentProperties(ApplicationApplicationConfigurationEnvironmentPropertiesArgs.builder()
.propertyGroups(
ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs.builder()
.propertyGroupId("PROPERTY-GROUP-1")
.propertyMap(Map.of("Key1", "Value1"))
.build(),
ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs.builder()
.propertyGroupId("PROPERTY-GROUP-2")
.propertyMap(Map.ofEntries(
Map.entry("KeyA", "ValueA"),
Map.entry("KeyB", "ValueB")
))
.build())
.build())
.flinkApplicationConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs.builder()
.checkpointConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs.builder()
.configurationType("DEFAULT")
.build())
.monitoringConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs.builder()
.configurationType("CUSTOM")
.logLevel("DEBUG")
.metricsLevel("TASK")
.build())
.parallelismConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.builder()
.autoScalingEnabled(true)
.configurationType("CUSTOM")
.parallelism(10)
.parallelismPerKpu(4)
.build())
.build())
.build())
.tags(Map.of("Environment", "test"))
.build());
}
}
import pulumi
import pulumi_aws as aws
example_bucket_v2 = aws.s3.BucketV2("exampleBucketV2")
example_bucket_objectv2 = aws.s3.BucketObjectv2("exampleBucketObjectv2",
bucket=example_bucket_v2.id,
key="example-flink-application",
source=pulumi.FileAsset("flink-app.jar"))
example_application = aws.kinesisanalyticsv2.Application("exampleApplication",
runtime_environment="FLINK-1_8",
service_execution_role=aws_iam_role["example"]["arn"],
application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationArgs(
application_code_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs(
code_content=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs(
s3_content_location=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs(
bucket_arn=example_bucket_v2.arn,
file_key=example_bucket_objectv2.key,
),
),
code_content_type="ZIPFILE",
),
environment_properties=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesArgs(
property_groups=[
aws.kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs(
property_group_id="PROPERTY-GROUP-1",
property_map={
"Key1": "Value1",
},
),
aws.kinesisanalyticsv2.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs(
property_group_id="PROPERTY-GROUP-2",
property_map={
"KeyA": "ValueA",
"KeyB": "ValueB",
},
),
],
),
flink_application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs(
checkpoint_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs(
configuration_type="DEFAULT",
),
monitoring_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs(
configuration_type="CUSTOM",
log_level="DEBUG",
metrics_level="TASK",
),
parallelism_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs(
auto_scaling_enabled=True,
configuration_type="CUSTOM",
parallelism=10,
parallelism_per_kpu=4,
),
),
),
tags={
"Environment": "test",
})
import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const exampleBucketV2 = new aws.s3.BucketV2("exampleBucketV2", {});
const exampleBucketObjectv2 = new aws.s3.BucketObjectv2("exampleBucketObjectv2", {
bucket: exampleBucketV2.id,
key: "example-flink-application",
source: new pulumi.asset.FileAsset("flink-app.jar"),
});
const exampleApplication = new aws.kinesisanalyticsv2.Application("exampleApplication", {
runtimeEnvironment: "FLINK-1_8",
serviceExecutionRole: aws_iam_role.example.arn,
applicationConfiguration: {
applicationCodeConfiguration: {
codeContent: {
s3ContentLocation: {
bucketArn: exampleBucketV2.arn,
fileKey: exampleBucketObjectv2.key,
},
},
codeContentType: "ZIPFILE",
},
environmentProperties: {
propertyGroups: [
{
propertyGroupId: "PROPERTY-GROUP-1",
propertyMap: {
Key1: "Value1",
},
},
{
propertyGroupId: "PROPERTY-GROUP-2",
propertyMap: {
KeyA: "ValueA",
KeyB: "ValueB",
},
},
],
},
flinkApplicationConfiguration: {
checkpointConfiguration: {
configurationType: "DEFAULT",
},
monitoringConfiguration: {
configurationType: "CUSTOM",
logLevel: "DEBUG",
metricsLevel: "TASK",
},
parallelismConfiguration: {
autoScalingEnabled: true,
configurationType: "CUSTOM",
parallelism: 10,
parallelismPerKpu: 4,
},
},
},
tags: {
Environment: "test",
},
});
resources:
exampleBucketV2:
type: aws:s3:BucketV2
exampleBucketObjectv2:
type: aws:s3:BucketObjectv2
properties:
bucket: ${exampleBucketV2.id}
key: example-flink-application
source:
fn::FileAsset: flink-app.jar
exampleApplication:
type: aws:kinesisanalyticsv2:Application
properties:
runtimeEnvironment: FLINK-1_8
serviceExecutionRole: ${aws_iam_role.example.arn}
applicationConfiguration:
applicationCodeConfiguration:
codeContent:
s3ContentLocation:
bucketArn: ${exampleBucketV2.arn}
fileKey: ${exampleBucketObjectv2.key}
codeContentType: ZIPFILE
environmentProperties:
propertyGroups:
- propertyGroupId: PROPERTY-GROUP-1
propertyMap:
Key1: Value1
- propertyGroupId: PROPERTY-GROUP-2
propertyMap:
KeyA: ValueA
KeyB: ValueB
flinkApplicationConfiguration:
checkpointConfiguration:
configurationType: DEFAULT
monitoringConfiguration:
configurationType: CUSTOM
logLevel: DEBUG
metricsLevel: TASK
parallelismConfiguration:
autoScalingEnabled: true
configurationType: CUSTOM
parallelism: 10
parallelismPerKpu: 4
tags:
Environment: test
SQL Application
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
var exampleLogGroup = new Aws.CloudWatch.LogGroup("exampleLogGroup");
var exampleLogStream = new Aws.CloudWatch.LogStream("exampleLogStream", new()
{
LogGroupName = exampleLogGroup.Name,
});
var exampleApplication = new Aws.KinesisAnalyticsV2.Application("exampleApplication", new()
{
RuntimeEnvironment = "SQL-1_0",
ServiceExecutionRole = aws_iam_role.Example.Arn,
ApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationArgs
{
ApplicationCodeConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs
{
CodeContent = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs
{
TextContent = @"SELECT 1;
",
},
CodeContentType = "PLAINTEXT",
},
SqlApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs
{
Input = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs
{
NamePrefix = "PREFIX_1",
InputParallelism = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs
{
Count = 3,
},
InputSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs
{
RecordColumns = new[]
{
new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs
{
Name = "COLUMN_1",
SqlType = "VARCHAR(8)",
Mapping = "MAPPING-1",
},
new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs
{
Name = "COLUMN_2",
SqlType = "DOUBLE",
},
},
RecordEncoding = "UTF-8",
RecordFormat = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs
{
RecordFormatType = "CSV",
MappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs
{
CsvMappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs
{
RecordColumnDelimiter = ",",
RecordRowDelimiter = @"
",
},
},
},
},
KinesisStreamsInput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs
{
ResourceArn = aws_kinesis_stream.Example.Arn,
},
},
Outputs = new[]
{
new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs
{
Name = "OUTPUT_1",
DestinationSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs
{
RecordFormatType = "JSON",
},
LambdaOutput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs
{
ResourceArn = aws_lambda_function.Example.Arn,
},
},
new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs
{
Name = "OUTPUT_2",
DestinationSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs
{
RecordFormatType = "CSV",
},
KinesisFirehoseOutput = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs
{
ResourceArn = aws_kinesis_firehose_delivery_stream.Example.Arn,
},
},
},
ReferenceDataSource = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs
{
TableName = "TABLE-1",
ReferenceSchema = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs
{
RecordColumns = new[]
{
new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs
{
Name = "COLUMN_1",
SqlType = "INTEGER",
},
},
RecordFormat = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs
{
RecordFormatType = "JSON",
MappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs
{
JsonMappingParameters = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs
{
RecordRowPath = "$",
},
},
},
},
S3ReferenceDataSource = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs
{
BucketArn = aws_s3_bucket.Example.Arn,
FileKey = "KEY-1",
},
},
},
},
CloudwatchLoggingOptions = new Aws.KinesisAnalyticsV2.Inputs.ApplicationCloudwatchLoggingOptionsArgs
{
LogStreamArn = exampleLogStream.Arn,
},
});
});
package main
import (
"github.com/pulumi/pulumi-aws/sdk/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.ApplicationApplicationConfigurationSqlApplicationConfigurationInputTypeArgs{
NamePrefix: pulumi.String("PREFIX_1"),
InputParallelism: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs{
Count: pulumi.Int(3),
},
InputSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs{
RecordColumns: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArray{
&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs{
Name: pulumi.String("COLUMN_1"),
SqlType: pulumi.String("VARCHAR(8)"),
Mapping: pulumi.String("MAPPING-1"),
},
&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs{
Name: pulumi.String("COLUMN_2"),
SqlType: pulumi.String("DOUBLE"),
},
},
RecordEncoding: pulumi.String("UTF-8"),
RecordFormat: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs{
RecordFormatType: pulumi.String("CSV"),
MappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs{
CsvMappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs{
RecordColumnDelimiter: pulumi.String(","),
RecordRowDelimiter: pulumi.String("\n"),
},
},
},
},
KinesisStreamsInput: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs{
ResourceArn: pulumi.Any(aws_kinesis_stream.Example.Arn),
},
},
Outputs: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArray{
&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArgs{
Name: pulumi.String("OUTPUT_1"),
DestinationSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs{
RecordFormatType: pulumi.String("JSON"),
},
LambdaOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs{
ResourceArn: pulumi.Any(aws_lambda_function.Example.Arn),
},
},
&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputTypeArgs{
Name: pulumi.String("OUTPUT_2"),
DestinationSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs{
RecordFormatType: pulumi.String("CSV"),
},
KinesisFirehoseOutput: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs{
ResourceArn: pulumi.Any(aws_kinesis_firehose_delivery_stream.Example.Arn),
},
},
},
ReferenceDataSource: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs{
TableName: pulumi.String("TABLE-1"),
ReferenceSchema: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs{
RecordColumns: kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArray{
&kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs{
Name: pulumi.String("COLUMN_1"),
SqlType: pulumi.String("INTEGER"),
},
},
RecordFormat: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs{
RecordFormatType: pulumi.String("JSON"),
MappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs{
JsonMappingParameters: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs{
RecordRowPath: pulumi.String("$"),
},
},
},
},
S3ReferenceDataSource: &kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs{
BucketArn: pulumi.Any(aws_s3_bucket.Example.Arn),
FileKey: pulumi.String("KEY-1"),
},
},
},
},
CloudwatchLoggingOptions: &kinesisanalyticsv2.ApplicationCloudwatchLoggingOptionsArgs{
LogStreamArn: exampleLogStream.Arn,
},
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.cloudwatch.LogGroup;
import com.pulumi.aws.cloudwatch.LogStream;
import com.pulumi.aws.cloudwatch.LogStreamArgs;
import com.pulumi.aws.kinesisanalyticsv2.Application;
import com.pulumi.aws.kinesisanalyticsv2.ApplicationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationCloudwatchLoggingOptionsArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var exampleLogGroup = new LogGroup("exampleLogGroup");
var exampleLogStream = new LogStream("exampleLogStream", LogStreamArgs.builder()
.logGroupName(exampleLogGroup.name())
.build());
var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()
.runtimeEnvironment("SQL-1_0")
.serviceExecutionRole(aws_iam_role.example().arn())
.applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
.applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
.codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
.textContent("""
SELECT 1;
""")
.build())
.codeContentType("PLAINTEXT")
.build())
.sqlApplicationConfiguration(ApplicationApplicationConfigurationSqlApplicationConfigurationArgs.builder()
.input(ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs.builder()
.namePrefix("PREFIX_1")
.inputParallelism(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs.builder()
.count(3)
.build())
.inputSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs.builder()
.recordColumns(
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs.builder()
.name("COLUMN_1")
.sqlType("VARCHAR(8)")
.mapping("MAPPING-1")
.build(),
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs.builder()
.name("COLUMN_2")
.sqlType("DOUBLE")
.build())
.recordEncoding("UTF-8")
.recordFormat(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs.builder()
.recordFormatType("CSV")
.mappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs.builder()
.csvMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs.builder()
.recordColumnDelimiter(",")
.recordRowDelimiter("""
""")
.build())
.build())
.build())
.build())
.kinesisStreamsInput(ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs.builder()
.resourceArn(aws_kinesis_stream.example().arn())
.build())
.build())
.outputs(
ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs.builder()
.name("OUTPUT_1")
.destinationSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs.builder()
.recordFormatType("JSON")
.build())
.lambdaOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs.builder()
.resourceArn(aws_lambda_function.example().arn())
.build())
.build(),
ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs.builder()
.name("OUTPUT_2")
.destinationSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs.builder()
.recordFormatType("CSV")
.build())
.kinesisFirehoseOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs.builder()
.resourceArn(aws_kinesis_firehose_delivery_stream.example().arn())
.build())
.build())
.referenceDataSource(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs.builder()
.tableName("TABLE-1")
.referenceSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs.builder()
.recordColumns(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs.builder()
.name("COLUMN_1")
.sqlType("INTEGER")
.build())
.recordFormat(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs.builder()
.recordFormatType("JSON")
.mappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs.builder()
.jsonMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs.builder()
.recordRowPath("$")
.build())
.build())
.build())
.build())
.s3ReferenceDataSource(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs.builder()
.bucketArn(aws_s3_bucket.example().arn())
.fileKey("KEY-1")
.build())
.build())
.build())
.build())
.cloudwatchLoggingOptions(ApplicationCloudwatchLoggingOptionsArgs.builder()
.logStreamArn(exampleLogStream.arn())
.build())
.build());
}
}
import pulumi
import pulumi_aws as aws
example_log_group = aws.cloudwatch.LogGroup("exampleLogGroup")
example_log_stream = aws.cloudwatch.LogStream("exampleLogStream", log_group_name=example_log_group.name)
example_application = aws.kinesisanalyticsv2.Application("exampleApplication",
runtime_environment="SQL-1_0",
service_execution_role=aws_iam_role["example"]["arn"],
application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationArgs(
application_code_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs(
code_content=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs(
text_content="SELECT 1;\n",
),
code_content_type="PLAINTEXT",
),
sql_application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs(
input=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs(
name_prefix="PREFIX_1",
input_parallelism=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs(
count=3,
),
input_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs(
record_columns=[
aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs(
name="COLUMN_1",
sql_type="VARCHAR(8)",
mapping="MAPPING-1",
),
aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs(
name="COLUMN_2",
sql_type="DOUBLE",
),
],
record_encoding="UTF-8",
record_format=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs(
record_format_type="CSV",
mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs(
csv_mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs(
record_column_delimiter=",",
record_row_delimiter="\n",
),
),
),
),
kinesis_streams_input=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs(
resource_arn=aws_kinesis_stream["example"]["arn"],
),
),
outputs=[
aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs(
name="OUTPUT_1",
destination_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs(
record_format_type="JSON",
),
lambda_output=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs(
resource_arn=aws_lambda_function["example"]["arn"],
),
),
aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs(
name="OUTPUT_2",
destination_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs(
record_format_type="CSV",
),
kinesis_firehose_output=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs(
resource_arn=aws_kinesis_firehose_delivery_stream["example"]["arn"],
),
),
],
reference_data_source=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs(
table_name="TABLE-1",
reference_schema=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs(
record_columns=[aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs(
name="COLUMN_1",
sql_type="INTEGER",
)],
record_format=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs(
record_format_type="JSON",
mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs(
json_mapping_parameters=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs(
record_row_path="$",
),
),
),
),
s3_reference_data_source=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs(
bucket_arn=aws_s3_bucket["example"]["arn"],
file_key="KEY-1",
),
),
),
),
cloudwatch_logging_options=aws.kinesisanalyticsv2.ApplicationCloudwatchLoggingOptionsArgs(
log_stream_arn=example_log_stream.arn,
))
import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const exampleLogGroup = new aws.cloudwatch.LogGroup("exampleLogGroup", {});
const exampleLogStream = new aws.cloudwatch.LogStream("exampleLogStream", {logGroupName: exampleLogGroup.name});
const exampleApplication = new aws.kinesisanalyticsv2.Application("exampleApplication", {
runtimeEnvironment: "SQL-1_0",
serviceExecutionRole: aws_iam_role.example.arn,
applicationConfiguration: {
applicationCodeConfiguration: {
codeContent: {
textContent: "SELECT 1;\n",
},
codeContentType: "PLAINTEXT",
},
sqlApplicationConfiguration: {
input: {
namePrefix: "PREFIX_1",
inputParallelism: {
count: 3,
},
inputSchema: {
recordColumns: [
{
name: "COLUMN_1",
sqlType: "VARCHAR(8)",
mapping: "MAPPING-1",
},
{
name: "COLUMN_2",
sqlType: "DOUBLE",
},
],
recordEncoding: "UTF-8",
recordFormat: {
recordFormatType: "CSV",
mappingParameters: {
csvMappingParameters: {
recordColumnDelimiter: ",",
recordRowDelimiter: "\n",
},
},
},
},
kinesisStreamsInput: {
resourceArn: aws_kinesis_stream.example.arn,
},
},
outputs: [
{
name: "OUTPUT_1",
destinationSchema: {
recordFormatType: "JSON",
},
lambdaOutput: {
resourceArn: aws_lambda_function.example.arn,
},
},
{
name: "OUTPUT_2",
destinationSchema: {
recordFormatType: "CSV",
},
kinesisFirehoseOutput: {
resourceArn: aws_kinesis_firehose_delivery_stream.example.arn,
},
},
],
referenceDataSource: {
tableName: "TABLE-1",
referenceSchema: {
recordColumns: [{
name: "COLUMN_1",
sqlType: "INTEGER",
}],
recordFormat: {
recordFormatType: "JSON",
mappingParameters: {
jsonMappingParameters: {
recordRowPath: "$",
},
},
},
},
s3ReferenceDataSource: {
bucketArn: aws_s3_bucket.example.arn,
fileKey: "KEY-1",
},
},
},
},
cloudwatchLoggingOptions: {
logStreamArn: exampleLogStream.arn,
},
});
resources:
exampleLogGroup:
type: aws:cloudwatch:LogGroup
exampleLogStream:
type: aws:cloudwatch:LogStream
properties:
logGroupName: ${exampleLogGroup.name}
exampleApplication:
type: aws:kinesisanalyticsv2:Application
properties:
runtimeEnvironment: SQL-1_0
serviceExecutionRole: ${aws_iam_role.example.arn}
applicationConfiguration:
applicationCodeConfiguration:
codeContent:
textContent: |
SELECT 1;
codeContentType: PLAINTEXT
sqlApplicationConfiguration:
input:
namePrefix: PREFIX_1
inputParallelism:
count: 3
inputSchema:
recordColumns:
- name: COLUMN_1
sqlType: VARCHAR(8)
mapping: MAPPING-1
- name: COLUMN_2
sqlType: DOUBLE
recordEncoding: UTF-8
recordFormat:
recordFormatType: CSV
mappingParameters:
csvMappingParameters:
recordColumnDelimiter: ','
recordRowDelimiter: |2+
kinesisStreamsInput:
resourceArn: ${aws_kinesis_stream.example.arn}
outputs:
- name: OUTPUT_1
destinationSchema:
recordFormatType: JSON
lambdaOutput:
resourceArn: ${aws_lambda_function.example.arn}
- name: OUTPUT_2
destinationSchema:
recordFormatType: CSV
kinesisFirehoseOutput:
resourceArn: ${aws_kinesis_firehose_delivery_stream.example.arn}
referenceDataSource:
tableName: TABLE-1
referenceSchema:
recordColumns:
- name: COLUMN_1
sqlType: INTEGER
recordFormat:
recordFormatType: JSON
mappingParameters:
jsonMappingParameters:
recordRowPath: $
s3ReferenceDataSource:
bucketArn: ${aws_s3_bucket.example.arn}
fileKey: KEY-1
cloudwatchLoggingOptions:
logStreamArn: ${exampleLogStream.arn}
VPC Configuration
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
var exampleBucketV2 = new Aws.S3.BucketV2("exampleBucketV2");
var exampleBucketObjectv2 = new Aws.S3.BucketObjectv2("exampleBucketObjectv2", new()
{
Bucket = exampleBucketV2.Id,
Key = "example-flink-application",
Source = new FileAsset("flink-app.jar"),
});
var exampleApplication = new Aws.KinesisAnalyticsV2.Application("exampleApplication", new()
{
RuntimeEnvironment = "FLINK-1_8",
ServiceExecutionRole = aws_iam_role.Example.Arn,
ApplicationConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationArgs
{
ApplicationCodeConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs
{
CodeContent = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs
{
S3ContentLocation = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs
{
BucketArn = exampleBucketV2.Arn,
FileKey = exampleBucketObjectv2.Key,
},
},
CodeContentType = "ZIPFILE",
},
VpcConfiguration = new Aws.KinesisAnalyticsV2.Inputs.ApplicationApplicationConfigurationVpcConfigurationArgs
{
SecurityGroupIds = new[]
{
aws_security_group.Example[0].Id,
aws_security_group.Example[1].Id,
},
SubnetIds = new[]
{
aws_subnet.Example.Id,
},
},
},
});
});
package main
import (
"github.com/pulumi/pulumi-aws/sdk/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.ID(),
Key: pulumi.String("example-flink-application"),
Source: pulumi.NewFileAsset("flink-app.jar"),
})
if err != nil {
return err
}
_, err = kinesisanalyticsv2.NewApplication(ctx, "exampleApplication", &kinesisanalyticsv2.ApplicationArgs{
RuntimeEnvironment: pulumi.String("FLINK-1_8"),
ServiceExecutionRole: pulumi.Any(aws_iam_role.Example.Arn),
ApplicationConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationArgs{
ApplicationCodeConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs{
CodeContent: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs{
S3ContentLocation: &kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs{
BucketArn: exampleBucketV2.Arn,
FileKey: exampleBucketObjectv2.Key,
},
},
CodeContentType: pulumi.String("ZIPFILE"),
},
VpcConfiguration: &kinesisanalyticsv2.ApplicationApplicationConfigurationVpcConfigurationArgs{
SecurityGroupIds: pulumi.StringArray{
aws_security_group.Example[0].Id,
aws_security_group.Example[1].Id,
},
SubnetIds: pulumi.StringArray{
aws_subnet.Example.Id,
},
},
},
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.s3.BucketV2;
import com.pulumi.aws.s3.BucketObjectv2;
import com.pulumi.aws.s3.BucketObjectv2Args;
import com.pulumi.aws.kinesisanalyticsv2.Application;
import com.pulumi.aws.kinesisanalyticsv2.ApplicationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs;
import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationVpcConfigurationArgs;
import com.pulumi.asset.FileAsset;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var exampleBucketV2 = new BucketV2("exampleBucketV2");
var exampleBucketObjectv2 = new BucketObjectv2("exampleBucketObjectv2", BucketObjectv2Args.builder()
.bucket(exampleBucketV2.id())
.key("example-flink-application")
.source(new FileAsset("flink-app.jar"))
.build());
var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()
.runtimeEnvironment("FLINK-1_8")
.serviceExecutionRole(aws_iam_role.example().arn())
.applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
.applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
.codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
.s3ContentLocation(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs.builder()
.bucketArn(exampleBucketV2.arn())
.fileKey(exampleBucketObjectv2.key())
.build())
.build())
.codeContentType("ZIPFILE")
.build())
.vpcConfiguration(ApplicationApplicationConfigurationVpcConfigurationArgs.builder()
.securityGroupIds(
aws_security_group.example()[0].id(),
aws_security_group.example()[1].id())
.subnetIds(aws_subnet.example().id())
.build())
.build())
.build());
}
}
import pulumi
import pulumi_aws as aws
example_bucket_v2 = aws.s3.BucketV2("exampleBucketV2")
example_bucket_objectv2 = aws.s3.BucketObjectv2("exampleBucketObjectv2",
bucket=example_bucket_v2.id,
key="example-flink-application",
source=pulumi.FileAsset("flink-app.jar"))
example_application = aws.kinesisanalyticsv2.Application("exampleApplication",
runtime_environment="FLINK-1_8",
service_execution_role=aws_iam_role["example"]["arn"],
application_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationArgs(
application_code_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs(
code_content=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs(
s3_content_location=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs(
bucket_arn=example_bucket_v2.arn,
file_key=example_bucket_objectv2.key,
),
),
code_content_type="ZIPFILE",
),
vpc_configuration=aws.kinesisanalyticsv2.ApplicationApplicationConfigurationVpcConfigurationArgs(
security_group_ids=[
aws_security_group["example"][0]["id"],
aws_security_group["example"][1]["id"],
],
subnet_ids=[aws_subnet["example"]["id"]],
),
))
import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const exampleBucketV2 = new aws.s3.BucketV2("exampleBucketV2", {});
const exampleBucketObjectv2 = new aws.s3.BucketObjectv2("exampleBucketObjectv2", {
bucket: exampleBucketV2.id,
key: "example-flink-application",
source: new pulumi.asset.FileAsset("flink-app.jar"),
});
const exampleApplication = new aws.kinesisanalyticsv2.Application("exampleApplication", {
runtimeEnvironment: "FLINK-1_8",
serviceExecutionRole: aws_iam_role.example.arn,
applicationConfiguration: {
applicationCodeConfiguration: {
codeContent: {
s3ContentLocation: {
bucketArn: exampleBucketV2.arn,
fileKey: exampleBucketObjectv2.key,
},
},
codeContentType: "ZIPFILE",
},
vpcConfiguration: {
securityGroupIds: [
aws_security_group.example[0].id,
aws_security_group.example[1].id,
],
subnetIds: [aws_subnet.example.id],
},
},
});
resources:
exampleBucketV2:
type: aws:s3:BucketV2
exampleBucketObjectv2:
type: aws:s3:BucketObjectv2
properties:
bucket: ${exampleBucketV2.id}
key: example-flink-application
source:
fn::FileAsset: flink-app.jar
exampleApplication:
type: aws:kinesisanalyticsv2:Application
properties:
runtimeEnvironment: FLINK-1_8
serviceExecutionRole: ${aws_iam_role.example.arn}
applicationConfiguration:
applicationCodeConfiguration:
codeContent:
s3ContentLocation:
bucketArn: ${exampleBucketV2.arn}
fileKey: ${exampleBucketObjectv2.key}
codeContentType: ZIPFILE
vpcConfiguration:
securityGroupIds:
- ${aws_security_group.example[0].id}
- ${aws_security_group.example[1].id}
subnetIds:
- ${aws_subnet.example.id}
Create Application Resource
new Application(name: string, args: ApplicationArgs, opts?: CustomResourceOptions);@overload
def Application(resource_name: str,
opts: Optional[ResourceOptions] = None,
application_configuration: Optional[ApplicationApplicationConfigurationArgs] = None,
cloudwatch_logging_options: Optional[ApplicationCloudwatchLoggingOptionsArgs] = None,
description: Optional[str] = None,
force_stop: Optional[bool] = None,
name: Optional[str] = None,
runtime_environment: Optional[str] = None,
service_execution_role: Optional[str] = None,
start_application: Optional[bool] = None,
tags: Optional[Mapping[str, str]] = None)
@overload
def Application(resource_name: str,
args: ApplicationArgs,
opts: Optional[ResourceOptions] = None)func NewApplication(ctx *Context, name string, args ApplicationArgs, opts ...ResourceOption) (*Application, error)public Application(string name, ApplicationArgs args, CustomResourceOptions? opts = null)
public Application(String name, ApplicationArgs args)
public Application(String name, ApplicationArgs args, CustomResourceOptions options)
type: aws:kinesisanalyticsv2:Application
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.
- name string
- The unique name of the resource.
- args ApplicationArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- resource_name str
- The unique name of the resource.
- args ApplicationArgs
- The arguments to resource properties.
- opts ResourceOptions
- Bag of options to control resource's behavior.
- ctx Context
- Context object for the current deployment.
- name string
- The unique name of the resource.
- args ApplicationArgs
- The arguments to resource properties.
- opts ResourceOption
- Bag of options to control resource's behavior.
- name string
- The unique name of the resource.
- args ApplicationArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- name String
- The unique name of the resource.
- args ApplicationArgs
- The arguments to resource properties.
- options CustomResourceOptions
- Bag of options to control resource's behavior.
Application Resource Properties
To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.
Inputs
The Application resource accepts the following input properties:
- Runtime
Environment string The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- Service
Execution stringRole 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 ApplicationApplication Configuration Args The application's configuration
- Cloudwatch
Logging ApplicationOptions Cloudwatch Logging Options Args A CloudWatch log stream to monitor application configuration errors.
- Description string
A summary description of the application.
- Force
Stop bool Whether to force stop an unresponsive Flink-based application.
- Name string
The name of the application.
- Start
Application bool Whether to start or stop the application.
- Dictionary<string, string>
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level
- Runtime
Environment string The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- Service
Execution stringRole 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 ApplicationApplication Configuration Args The application's configuration
- Cloudwatch
Logging ApplicationOptions Cloudwatch Logging Options Args A CloudWatch log stream to monitor application configuration errors.
- Description string
A summary description of the application.
- Force
Stop bool Whether to force stop an unresponsive Flink-based application.
- Name string
The name of the application.
- Start
Application bool Whether to start or stop the application.
- map[string]string
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level
- runtime
Environment String The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- service
Execution StringRole 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 ApplicationApplication Configuration Args The application's configuration
- cloudwatch
Logging ApplicationOptions Cloudwatch Logging Options Args A CloudWatch log stream to monitor application configuration errors.
- description String
A summary description of the application.
- force
Stop Boolean Whether to force stop an unresponsive Flink-based application.
- name String
The name of the application.
- start
Application Boolean Whether to start or stop the application.
- Map<String,String>
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level
- runtime
Environment string The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- service
Execution stringRole 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 ApplicationApplication Configuration Args The application's configuration
- cloudwatch
Logging ApplicationOptions Cloudwatch Logging Options Args A CloudWatch log stream to monitor application configuration errors.
- description string
A summary description of the application.
- force
Stop boolean Whether to force stop an unresponsive Flink-based application.
- name string
The name of the application.
- start
Application boolean Whether to start or stop the application.
- {[key: string]: string}
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level
- runtime_
environment str The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- service_
execution_ strrole 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 ApplicationApplication Configuration Args The application's configuration
- cloudwatch_
logging_ Applicationoptions Cloudwatch Logging Options Args 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.
- Mapping[str, str]
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level
- runtime
Environment String The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- service
Execution StringRole 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 Property Map The application's configuration
- cloudwatch
Logging Property MapOptions A CloudWatch log stream to monitor application configuration errors.
- description String
A summary description of the application.
- force
Stop Boolean Whether to force stop an unresponsive Flink-based application.
- name String
The name of the application.
- start
Application Boolean Whether to start or stop the application.
- Map<String>
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration 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.
- Create
Timestamp string The current timestamp when the application was created.
- Id string
The provider-assigned unique ID for this managed resource.
- Last
Update stringTimestamp The current timestamp when the application was last updated.
- Status string
The status of the application.
- Dictionary<string, string>
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- Version
Id int The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
- Arn string
The ARN of the application.
- Create
Timestamp string The current timestamp when the application was created.
- Id string
The provider-assigned unique ID for this managed resource.
- Last
Update stringTimestamp The current timestamp when the application was last updated.
- Status string
The status of the application.
- map[string]string
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- Version
Id int The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
- arn String
The ARN of the application.
- create
Timestamp String The current timestamp when the application was created.
- id String
The provider-assigned unique ID for this managed resource.
- last
Update StringTimestamp The current timestamp when the application was last updated.
- status String
The status of the application.
- Map<String,String>
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- version
Id Integer The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
- arn string
The ARN of the application.
- create
Timestamp string The current timestamp when the application was created.
- id string
The provider-assigned unique ID for this managed resource.
- last
Update stringTimestamp The current timestamp when the application was last updated.
- status string
The status of the application.
- {[key: string]: string}
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- version
Id number The current application version. Kinesis Data Analytics updates the
version_ideach 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_ strtimestamp The current timestamp when the application was last updated.
- status str
The status of the application.
- Mapping[str, str]
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- version_
id int The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
- arn String
The ARN of the application.
- create
Timestamp String The current timestamp when the application was created.
- id String
The provider-assigned unique ID for this managed resource.
- last
Update StringTimestamp The current timestamp when the application was last updated.
- status String
The status of the application.
- Map<String>
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- version
Id Number The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
Look up Existing Application Resource
Get an existing Application resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.
public static get(name: string, id: Input<ID>, state?: ApplicationState, opts?: CustomResourceOptions): Application@staticmethod
def get(resource_name: str,
id: str,
opts: Optional[ResourceOptions] = None,
application_configuration: Optional[ApplicationApplicationConfigurationArgs] = None,
arn: Optional[str] = None,
cloudwatch_logging_options: Optional[ApplicationCloudwatchLoggingOptionsArgs] = None,
create_timestamp: Optional[str] = None,
description: Optional[str] = None,
force_stop: Optional[bool] = None,
last_update_timestamp: Optional[str] = None,
name: Optional[str] = None,
runtime_environment: Optional[str] = None,
service_execution_role: Optional[str] = None,
start_application: Optional[bool] = None,
status: Optional[str] = None,
tags: Optional[Mapping[str, str]] = None,
tags_all: Optional[Mapping[str, str]] = None,
version_id: Optional[int] = None) -> Applicationfunc 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.
- Application
Configuration ApplicationApplication Configuration Args The application's configuration
- Arn string
The ARN of the application.
- Cloudwatch
Logging ApplicationOptions Cloudwatch Logging Options Args A CloudWatch log stream to monitor application configuration errors.
- Create
Timestamp string The current timestamp when the application was created.
- Description string
A summary description of the application.
- Force
Stop bool Whether to force stop an unresponsive Flink-based application.
- Last
Update stringTimestamp The current timestamp when the application was last updated.
- Name string
The name of the application.
- Runtime
Environment string The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- Service
Execution stringRole 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 string
The status of the application.
- Dictionary<string, string>
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level- Dictionary<string, string>
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- Version
Id int The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
- Application
Configuration ApplicationApplication Configuration Args The application's configuration
- Arn string
The ARN of the application.
- Cloudwatch
Logging ApplicationOptions Cloudwatch Logging Options Args A CloudWatch log stream to monitor application configuration errors.
- Create
Timestamp string The current timestamp when the application was created.
- Description string
A summary description of the application.
- Force
Stop bool Whether to force stop an unresponsive Flink-based application.
- Last
Update stringTimestamp The current timestamp when the application was last updated.
- Name string
The name of the application.
- Runtime
Environment string The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- Service
Execution stringRole 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 string
The status of the application.
- map[string]string
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level- map[string]string
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- Version
Id int The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
- application
Configuration ApplicationApplication Configuration Args The application's configuration
- arn String
The ARN of the application.
- cloudwatch
Logging ApplicationOptions Cloudwatch Logging Options Args A CloudWatch log stream to monitor application configuration errors.
- create
Timestamp String The current timestamp when the application was created.
- description String
A summary description of the application.
- force
Stop Boolean Whether to force stop an unresponsive Flink-based application.
- last
Update StringTimestamp The current timestamp when the application was last updated.
- name String
The name of the application.
- runtime
Environment String The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- service
Execution StringRole 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 Boolean Whether to start or stop the application.
- status String
The status of the application.
- Map<String,String>
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level- Map<String,String>
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- version
Id Integer The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
- application
Configuration ApplicationApplication Configuration Args The application's configuration
- arn string
The ARN of the application.
- cloudwatch
Logging ApplicationOptions Cloudwatch Logging Options Args A CloudWatch log stream to monitor application configuration errors.
- create
Timestamp string The current timestamp when the application was created.
- description string
A summary description of the application.
- force
Stop boolean Whether to force stop an unresponsive Flink-based application.
- last
Update stringTimestamp The current timestamp when the application was last updated.
- name string
The name of the application.
- runtime
Environment string The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- service
Execution stringRole 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 boolean Whether to start or stop the application.
- status string
The status of the application.
- {[key: string]: string}
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level- {[key: string]: string}
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- version
Id number The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
- application_
configuration ApplicationApplication Configuration Args The application's configuration
- arn str
The ARN of the application.
- cloudwatch_
logging_ Applicationoptions Cloudwatch Logging Options Args 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_ strtimestamp The current timestamp when the application was last updated.
- name str
The name of the application.
- runtime_
environment str The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- service_
execution_ strrole 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.
- Mapping[str, str]
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level- Mapping[str, str]
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- version_
id int The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
- application
Configuration Property Map The application's configuration
- arn String
The ARN of the application.
- cloudwatch
Logging Property MapOptions A CloudWatch log stream to monitor application configuration errors.
- create
Timestamp String The current timestamp when the application was created.
- description String
A summary description of the application.
- force
Stop Boolean Whether to force stop an unresponsive Flink-based application.
- last
Update StringTimestamp The current timestamp when the application was last updated.
- name String
The name of the application.
- runtime
Environment String The runtime environment for the application. Valid values:
SQL-1_0,FLINK-1_6,FLINK-1_8,FLINK-1_11,FLINK-1_13,FLINK-1_15.- service
Execution StringRole 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 Boolean Whether to start or stop the application.
- status String
The status of the application.
- Map<String>
A map of tags to assign to the application. If configured with a provider
default_tagsconfiguration block present, tags with matching keys will overwrite those defined at the provider-level- Map<String>
A map of tags assigned to the resource, including those inherited from the provider
default_tagsconfiguration block.- version
Id Number The current application version. Kinesis Data Analytics updates the
version_ideach time the application is updated.
Supporting Types
ApplicationApplicationConfiguration
- Application
Code ApplicationConfiguration Application Configuration Application Code Configuration The code location and type parameters for the application.
- Application
Snapshot ApplicationConfiguration Application Configuration Application Snapshot Configuration Describes whether snapshots are enabled for a Flink-based application.
- Environment
Properties ApplicationApplication Configuration Environment Properties Describes execution properties for a Flink-based application.
- Flink
Application ApplicationConfiguration Application Configuration Flink Application Configuration The configuration of a Flink-based application.
- Run
Configuration ApplicationApplication Configuration Run Configuration Describes the starting properties for a Flink-based application.
- Sql
Application ApplicationConfiguration Application Configuration Sql Application Configuration The configuration of a SQL-based application.
- Vpc
Configuration ApplicationApplication Configuration Vpc Configuration The VPC configuration of a Flink-based application.
- Application
Code ApplicationConfiguration Application Configuration Application Code Configuration The code location and type parameters for the application.
- Application
Snapshot ApplicationConfiguration Application Configuration Application Snapshot Configuration Describes whether snapshots are enabled for a Flink-based application.
- Environment
Properties ApplicationApplication Configuration Environment Properties Describes execution properties for a Flink-based application.
- Flink
Application ApplicationConfiguration Application Configuration Flink Application Configuration The configuration of a Flink-based application.
- Run
Configuration ApplicationApplication Configuration Run Configuration Describes the starting properties for a Flink-based application.
- Sql
Application ApplicationConfiguration Application Configuration Sql Application Configuration The configuration of a SQL-based application.
- Vpc
Configuration ApplicationApplication Configuration Vpc Configuration The VPC configuration of a Flink-based application.
- application
Code ApplicationConfiguration Application Configuration Application Code Configuration The code location and type parameters for the application.
- application
Snapshot ApplicationConfiguration Application Configuration Application Snapshot Configuration Describes whether snapshots are enabled for a Flink-based application.
- environment
Properties ApplicationApplication Configuration Environment Properties Describes execution properties for a Flink-based application.
- flink
Application ApplicationConfiguration Application Configuration Flink Application Configuration The configuration of a Flink-based application.
- run
Configuration ApplicationApplication Configuration Run Configuration Describes the starting properties for a Flink-based application.
- sql
Application ApplicationConfiguration Application Configuration Sql Application Configuration The configuration of a SQL-based application.
- vpc
Configuration ApplicationApplication Configuration Vpc Configuration The VPC configuration of a Flink-based application.
- application
Code ApplicationConfiguration Application Configuration Application Code Configuration The code location and type parameters for the application.
- application
Snapshot ApplicationConfiguration Application Configuration Application Snapshot Configuration Describes whether snapshots are enabled for a Flink-based application.
- environment
Properties ApplicationApplication Configuration Environment Properties Describes execution properties for a Flink-based application.
- flink
Application ApplicationConfiguration Application Configuration Flink Application Configuration The configuration of a Flink-based application.
- run
Configuration ApplicationApplication Configuration Run Configuration Describes the starting properties for a Flink-based application.
- sql
Application ApplicationConfiguration Application Configuration Sql Application Configuration The configuration of a SQL-based application.
- vpc
Configuration ApplicationApplication Configuration Vpc Configuration The VPC configuration of a Flink-based application.
- application_
code_ Applicationconfiguration Application Configuration Application Code Configuration The code location and type parameters for the application.
- application_
snapshot_ Applicationconfiguration Application Configuration Application Snapshot Configuration Describes whether snapshots are enabled for a Flink-based application.
- environment_
properties ApplicationApplication Configuration Environment Properties Describes execution properties for a Flink-based application.
- flink_
application_ Applicationconfiguration Application Configuration Flink Application Configuration The configuration of a Flink-based application.
- run_
configuration ApplicationApplication Configuration Run Configuration Describes the starting properties for a Flink-based application.
- sql_
application_ Applicationconfiguration Application Configuration Sql Application Configuration The configuration of a SQL-based application.
- vpc_
configuration ApplicationApplication Configuration Vpc Configuration The VPC configuration of a Flink-based application.
- application
Code Property MapConfiguration The code location and type parameters for the application.
- application
Snapshot Property MapConfiguration Describes whether snapshots are enabled for a Flink-based application.
- environment
Properties Property Map Describes execution properties for a Flink-based application.
- flink
Application Property MapConfiguration The configuration of a Flink-based application.
- run
Configuration Property Map Describes the starting properties for a Flink-based application.
- sql
Application Property MapConfiguration The configuration of a SQL-based application.
- vpc
Configuration Property Map The VPC configuration of a Flink-based application.
ApplicationApplicationConfigurationApplicationCodeConfiguration
- Code
Content stringType Specifies whether the code content is in text or zip format. Valid values:
PLAINTEXT,ZIPFILE.- Code
Content ApplicationApplication Configuration Application Code Configuration Code Content The location and type of the application code.
- Code
Content stringType Specifies whether the code content is in text or zip format. Valid values:
PLAINTEXT,ZIPFILE.- Code
Content ApplicationApplication Configuration Application Code Configuration Code Content The location and type of the application code.
- code
Content StringType Specifies whether the code content is in text or zip format. Valid values:
PLAINTEXT,ZIPFILE.- code
Content ApplicationApplication Configuration Application Code Configuration Code Content The location and type of the application code.
- code
Content stringType Specifies whether the code content is in text or zip format. Valid values:
PLAINTEXT,ZIPFILE.- code
Content ApplicationApplication Configuration Application Code Configuration Code Content The location and type of the application code.
- code_
content_ strtype Specifies whether the code content is in text or zip format. Valid values:
PLAINTEXT,ZIPFILE.- code_
content ApplicationApplication Configuration Application Code Configuration Code Content The location and type of the application code.
- code
Content StringType Specifies whether the code content is in text or zip format. Valid values:
PLAINTEXT,ZIPFILE.- code
Content Property Map The location and type of the application code.
ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContent
- S3Content
Location ApplicationApplication Configuration Application Code Configuration Code Content S3Content Location Information about the Amazon S3 bucket containing the application code.
- Text
Content string The text-format code for the application.
- S3Content
Location ApplicationApplication Configuration Application Code Configuration Code Content S3Content Location Information about the Amazon S3 bucket containing the application code.
- Text
Content string The text-format code for the application.
- s3Content
Location ApplicationApplication Configuration Application Code Configuration Code Content S3Content Location Information about the Amazon S3 bucket containing the application code.
- text
Content String The text-format code for the application.
- s3Content
Location ApplicationApplication Configuration Application Code Configuration Code Content S3Content Location Information about the Amazon S3 bucket containing the application code.
- text
Content string The text-format code for the application.
- s3_
content_ Applicationlocation Application Configuration Application Code Configuration Code Content S3Content Location Information about the Amazon S3 bucket containing the application code.
- text_
content str The text-format code for the application.
- s3Content
Location Property Map Information about the Amazon S3 bucket containing the application code.
- text
Content String The text-format code for the application.
ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocation
- Bucket
Arn string The ARN for the S3 bucket containing the application code.
- File
Key string The file key for the object containing the application code.
- Object
Version string The version of the object containing the application code.
- Bucket
Arn string The ARN for the S3 bucket containing the application code.
- File
Key string The file key for the object containing the application code.
- Object
Version string The version of the object containing the application code.
- bucket
Arn String The ARN for the S3 bucket containing the application code.
- file
Key String The file key for the object containing the application code.
- object
Version String The version of the object containing the application code.
- bucket
Arn string The ARN for the S3 bucket containing the application code.
- file
Key string The file key for the object containing the application code.
- object
Version 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.
- bucket
Arn String The ARN for the S3 bucket containing the application code.
- file
Key String The file key for the object containing the application code.
- object
Version String The version of the object containing the application code.
ApplicationApplicationConfigurationApplicationSnapshotConfiguration
- Snapshots
Enabled bool 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.
- snapshots
Enabled Boolean Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
- snapshots
Enabled 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.
- snapshots
Enabled Boolean Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
ApplicationApplicationConfigurationEnvironmentProperties
- Property
Groups List<ApplicationApplication Configuration Environment Properties Property Group> Describes the execution property groups.
- Property
Groups []ApplicationApplication Configuration Environment Properties Property Group Describes the execution property groups.
- property
Groups List<ApplicationApplication Configuration Environment Properties Property Group> Describes the execution property groups.
- property
Groups ApplicationApplication Configuration Environment Properties Property Group[] Describes the execution property groups.
- property_
groups Sequence[ApplicationApplication Configuration Environment Properties Property Group] Describes the execution property groups.
- property
Groups List<Property Map> Describes the execution property groups.
ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroup
- Property
Group stringId The key of the application execution property key-value map.
- Property
Map Dictionary<string, string> Application execution property key-value map.
- Property
Group stringId The key of the application execution property key-value map.
- Property
Map map[string]string Application execution property key-value map.
- property
Group StringId The key of the application execution property key-value map.
- property
Map Map<String,String> Application execution property key-value map.
- property
Group stringId The key of the application execution property key-value map.
- property
Map {[key: string]: string} Application execution property key-value map.
- property_
group_ strid The key of the application execution property key-value map.
- property_
map Mapping[str, str] Application execution property key-value map.
- property
Group StringId The key of the application execution property key-value map.
- property
Map Map<String> Application execution property key-value map.
ApplicationApplicationConfigurationFlinkApplicationConfiguration
- Checkpoint
Configuration ApplicationApplication Configuration Flink Application Configuration Checkpoint Configuration Describes an application's checkpointing configuration.
- Monitoring
Configuration ApplicationApplication Configuration Flink Application Configuration Monitoring Configuration Describes configuration parameters for CloudWatch logging for an application.
- Parallelism
Configuration ApplicationApplication Configuration Flink Application Configuration Parallelism Configuration Describes parameters for how an application executes multiple tasks simultaneously.
- Checkpoint
Configuration ApplicationApplication Configuration Flink Application Configuration Checkpoint Configuration Describes an application's checkpointing configuration.
- Monitoring
Configuration ApplicationApplication Configuration Flink Application Configuration Monitoring Configuration Describes configuration parameters for CloudWatch logging for an application.
- Parallelism
Configuration ApplicationApplication Configuration Flink Application Configuration Parallelism Configuration Describes parameters for how an application executes multiple tasks simultaneously.
- checkpoint
Configuration ApplicationApplication Configuration Flink Application Configuration Checkpoint Configuration Describes an application's checkpointing configuration.
- monitoring
Configuration ApplicationApplication Configuration Flink Application Configuration Monitoring Configuration Describes configuration parameters for CloudWatch logging for an application.
- parallelism
Configuration ApplicationApplication Configuration Flink Application Configuration Parallelism Configuration Describes parameters for how an application executes multiple tasks simultaneously.
- checkpoint
Configuration ApplicationApplication Configuration Flink Application Configuration Checkpoint Configuration Describes an application's checkpointing configuration.
- monitoring
Configuration ApplicationApplication Configuration Flink Application Configuration Monitoring Configuration Describes configuration parameters for CloudWatch logging for an application.
- parallelism
Configuration ApplicationApplication Configuration Flink Application Configuration Parallelism Configuration Describes parameters for how an application executes multiple tasks simultaneously.
- checkpoint_
configuration ApplicationApplication Configuration Flink Application Configuration Checkpoint Configuration Describes an application's checkpointing configuration.
- monitoring_
configuration ApplicationApplication Configuration Flink Application Configuration Monitoring Configuration Describes configuration parameters for CloudWatch logging for an application.
- parallelism_
configuration ApplicationApplication Configuration Flink Application Configuration Parallelism Configuration Describes parameters for how an application executes multiple tasks simultaneously.
- checkpoint
Configuration Property Map Describes an application's checkpointing configuration.
- monitoring
Configuration Property Map Describes configuration parameters for CloudWatch logging for an application.
- parallelism
Configuration Property Map Describes parameters for how an application executes multiple tasks simultaneously.
ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfiguration
- Configuration
Type string Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedcheckpointing_enabled,checkpoint_interval, ormin_pause_between_checkpointsattribute values to be effective. If this attribute is set toDEFAULT, the application will always use the following values:checkpointing_enabled = truecheckpoint_interval = 60000min_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 intBetween Checkpoints Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
- Configuration
Type string Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedcheckpointing_enabled,checkpoint_interval, ormin_pause_between_checkpointsattribute values to be effective. If this attribute is set toDEFAULT, the application will always use the following values:checkpointing_enabled = truecheckpoint_interval = 60000min_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 intBetween Checkpoints Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
- configuration
Type String Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedcheckpointing_enabled,checkpoint_interval, ormin_pause_between_checkpointsattribute values to be effective. If this attribute is set toDEFAULT, the application will always use the following values:checkpointing_enabled = truecheckpoint_interval = 60000min_pause_between_checkpoints = 5000
- checkpoint
Interval Integer Describes the interval in milliseconds between checkpoint operations.
- checkpointing
Enabled Boolean Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
- min
Pause IntegerBetween Checkpoints Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
- configuration
Type string Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedcheckpointing_enabled,checkpoint_interval, ormin_pause_between_checkpointsattribute values to be effective. If this attribute is set toDEFAULT, the application will always use the following values:checkpointing_enabled = truecheckpoint_interval = 60000min_pause_between_checkpoints = 5000
- checkpoint
Interval number Describes the interval in milliseconds between checkpoint operations.
- checkpointing
Enabled boolean Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
- min
Pause numberBetween Checkpoints 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 toCUSTOMin order for any specifiedcheckpointing_enabled,checkpoint_interval, ormin_pause_between_checkpointsattribute values to be effective. If this attribute is set toDEFAULT, the application will always use the following values:checkpointing_enabled = truecheckpoint_interval = 60000min_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_ intbetween_ checkpoints Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
- configuration
Type String Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedcheckpointing_enabled,checkpoint_interval, ormin_pause_between_checkpointsattribute values to be effective. If this attribute is set toDEFAULT, the application will always use the following values:checkpointing_enabled = truecheckpoint_interval = 60000min_pause_between_checkpoints = 5000
- checkpoint
Interval Number Describes the interval in milliseconds between checkpoint operations.
- checkpointing
Enabled Boolean Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
- min
Pause NumberBetween Checkpoints Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfiguration
- Configuration
Type string Describes whether to use the default CloudWatch logging configuration for an application. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedlog_levelormetrics_levelattribute values to be effective.- Log
Level string Describes the verbosity of the CloudWatch Logs for an application. Valid values:
DEBUG,ERROR,INFO,WARN.- Metrics
Level string Describes the granularity of the CloudWatch Logs for an application. Valid values:
APPLICATION,OPERATOR,PARALLELISM,TASK.
- Configuration
Type string Describes whether to use the default CloudWatch logging configuration for an application. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedlog_levelormetrics_levelattribute values to be effective.- Log
Level string Describes the verbosity of the CloudWatch Logs for an application. Valid values:
DEBUG,ERROR,INFO,WARN.- Metrics
Level string Describes the granularity of the CloudWatch Logs for an application. Valid values:
APPLICATION,OPERATOR,PARALLELISM,TASK.
- configuration
Type String Describes whether to use the default CloudWatch logging configuration for an application. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedlog_levelormetrics_levelattribute values to be effective.- log
Level String Describes the verbosity of the CloudWatch Logs for an application. Valid values:
DEBUG,ERROR,INFO,WARN.- metrics
Level String Describes the granularity of the CloudWatch Logs for an application. Valid values:
APPLICATION,OPERATOR,PARALLELISM,TASK.
- configuration
Type string Describes whether to use the default CloudWatch logging configuration for an application. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedlog_levelormetrics_levelattribute values to be effective.- log
Level string Describes the verbosity of the CloudWatch Logs for an application. Valid values:
DEBUG,ERROR,INFO,WARN.- metrics
Level 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 toCUSTOMin order for any specifiedlog_levelormetrics_levelattribute 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.
- configuration
Type String Describes whether to use the default CloudWatch logging configuration for an application. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedlog_levelormetrics_levelattribute values to be effective.- log
Level String Describes the verbosity of the CloudWatch Logs for an application. Valid values:
DEBUG,ERROR,INFO,WARN.- metrics
Level String Describes the granularity of the CloudWatch Logs for an application. Valid values:
APPLICATION,OPERATOR,PARALLELISM,TASK.
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration
- Configuration
Type string Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedauto_scaling_enabled,parallelism, orparallelism_per_kpuattribute values to be effective.- Auto
Scaling boolEnabled 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 intKpu 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 string Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedauto_scaling_enabled,parallelism, orparallelism_per_kpuattribute values to be effective.- Auto
Scaling boolEnabled 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 intKpu 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 String Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedauto_scaling_enabled,parallelism, orparallelism_per_kpuattribute values to be effective.- auto
Scaling BooleanEnabled 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.
- parallelism
Per IntegerKpu 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 string Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedauto_scaling_enabled,parallelism, orparallelism_per_kpuattribute values to be effective.- auto
Scaling booleanEnabled 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.
- parallelism
Per numberKpu 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 toCUSTOMin order for any specifiedauto_scaling_enabled,parallelism, orparallelism_per_kpuattribute values to be effective.- auto_
scaling_ boolenabled 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_ intkpu 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 String Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values:
CUSTOM,DEFAULT. Set this attribute toCUSTOMin order for any specifiedauto_scaling_enabled,parallelism, orparallelism_per_kpuattribute values to be effective.- auto
Scaling BooleanEnabled 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.
- parallelism
Per NumberKpu 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
- Application
Restore ApplicationConfiguration Application Configuration Run Configuration Application Restore Configuration The restore behavior of a restarting application.
- Flink
Run ApplicationConfiguration Application Configuration Run Configuration Flink Run Configuration The starting parameters for a Flink-based Kinesis Data Analytics application.
- Application
Restore ApplicationConfiguration Application Configuration Run Configuration Application Restore Configuration The restore behavior of a restarting application.
- Flink
Run ApplicationConfiguration Application Configuration Run Configuration Flink Run Configuration The starting parameters for a Flink-based Kinesis Data Analytics application.
- application
Restore ApplicationConfiguration Application Configuration Run Configuration Application Restore Configuration The restore behavior of a restarting application.
- flink
Run ApplicationConfiguration Application Configuration Run Configuration Flink Run Configuration The starting parameters for a Flink-based Kinesis Data Analytics application.
- application
Restore ApplicationConfiguration Application Configuration Run Configuration Application Restore Configuration The restore behavior of a restarting application.
- flink
Run ApplicationConfiguration Application Configuration Run Configuration Flink Run Configuration The starting parameters for a Flink-based Kinesis Data Analytics application.
- application_
restore_ Applicationconfiguration Application Configuration Run Configuration Application Restore Configuration The restore behavior of a restarting application.
- flink_
run_ Applicationconfiguration Application Configuration Run Configuration Flink Run Configuration The starting parameters for a Flink-based Kinesis Data Analytics application.
- application
Restore Property MapConfiguration The restore behavior of a restarting application.
- flink
Run Property MapConfiguration The starting parameters for a Flink-based Kinesis Data Analytics application.
ApplicationApplicationConfigurationRunConfigurationApplicationRestoreConfiguration
- Application
Restore stringType Specifies how the application should be restored. Valid values:
RESTORE_FROM_CUSTOM_SNAPSHOT,RESTORE_FROM_LATEST_SNAPSHOT,SKIP_RESTORE_FROM_SNAPSHOT.- Snapshot
Name 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_SNAPSHOTis specified forapplication_restore_type.
- Application
Restore stringType Specifies how the application should be restored. Valid values:
RESTORE_FROM_CUSTOM_SNAPSHOT,RESTORE_FROM_LATEST_SNAPSHOT,SKIP_RESTORE_FROM_SNAPSHOT.- Snapshot
Name 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_SNAPSHOTis specified forapplication_restore_type.
- application
Restore StringType Specifies how the application should be restored. Valid values:
RESTORE_FROM_CUSTOM_SNAPSHOT,RESTORE_FROM_LATEST_SNAPSHOT,SKIP_RESTORE_FROM_SNAPSHOT.- snapshot
Name 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_SNAPSHOTis specified forapplication_restore_type.
- application
Restore stringType Specifies how the application should be restored. Valid values:
RESTORE_FROM_CUSTOM_SNAPSHOT,RESTORE_FROM_LATEST_SNAPSHOT,SKIP_RESTORE_FROM_SNAPSHOT.- snapshot
Name 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_SNAPSHOTis specified forapplication_restore_type.
- application_
restore_ strtype 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_SNAPSHOTis specified forapplication_restore_type.
- application
Restore StringType Specifies how the application should be restored. Valid values:
RESTORE_FROM_CUSTOM_SNAPSHOT,RESTORE_FROM_LATEST_SNAPSHOT,SKIP_RESTORE_FROM_SNAPSHOT.- snapshot
Name 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_SNAPSHOTis specified forapplication_restore_type.
ApplicationApplicationConfigurationRunConfigurationFlinkRunConfiguration
- Allow
Non boolRestored State 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 boolRestored State 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 BooleanRestored State 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 booleanRestored State 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_ boolrestored_ state 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 BooleanRestored State 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
Application
Application Configuration Sql Application Configuration Input The input stream used by the application.
- Outputs
List<Application
Application Configuration Sql Application Configuration Output> The destination streams used by the application.
- Reference
Data ApplicationSource Application Configuration Sql Application Configuration Reference Data Source The reference data source used by the application.
- Input
Application
Application Configuration Sql Application Configuration Input Type The input stream used by the application.
- Outputs
[]Application
Application Configuration Sql Application Configuration Output Type The destination streams used by the application.
- Reference
Data ApplicationSource Application Configuration Sql Application Configuration Reference Data Source The reference data source used by the application.
- input
Application
Application Configuration Sql Application Configuration Input The input stream used by the application.
- outputs
List<Application
Application Configuration Sql Application Configuration Output> The destination streams used by the application.
- reference
Data ApplicationSource Application Configuration Sql Application Configuration Reference Data Source The reference data source used by the application.
- input
Application
Application Configuration Sql Application Configuration Input The input stream used by the application.
- outputs
Application
Application Configuration Sql Application Configuration Output[] The destination streams used by the application.
- reference
Data ApplicationSource Application Configuration Sql Application Configuration Reference Data Source The reference data source used by the application.
- input
Application
Application Configuration Sql Application Configuration Input The input stream used by the application.
- outputs
Sequence[Application
Application Configuration Sql Application Configuration Output] The destination streams used by the application.
- reference_
data_ Applicationsource Application Configuration Sql Application Configuration Reference Data Source The reference data source used by the application.
- input Property Map
The input stream used by the application.
- outputs List<Property Map>
The destination streams used by the application.
- reference
Data Property MapSource The reference data source used by the application.
ApplicationApplicationConfigurationSqlApplicationConfigurationInput
- Input
Schema ApplicationApplication Configuration Sql Application Configuration Input Input Schema 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 string The name prefix to use when creating an in-application stream.
- In
App List<string>Stream Names - Input
Id string - Input
Parallelism ApplicationApplication Configuration Sql Application Configuration Input Input Parallelism Describes the number of in-application streams to create.
- Input
Processing ApplicationConfiguration Application Configuration Sql Application Configuration Input Input Processing Configuration 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 List<ApplicationPosition Configurations Application Configuration Sql Application Configuration Input Input Starting Position Configuration> The point at which the application starts processing records from the streaming source.
- Kinesis
Firehose ApplicationInput Application Configuration Sql Application Configuration Input Kinesis Firehose Input If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
- Kinesis
Streams ApplicationInput Application Configuration Sql Application Configuration Input Kinesis Streams Input If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
- Input
Schema ApplicationApplication Configuration Sql Application Configuration Input Input Schema 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 string The name prefix to use when creating an in-application stream.
- In
App []stringStream Names - Input
Id string - Input
Parallelism ApplicationApplication Configuration Sql Application Configuration Input Input Parallelism Describes the number of in-application streams to create.
- Input
Processing ApplicationConfiguration Application Configuration Sql Application Configuration Input Input Processing Configuration 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 []ApplicationPosition Configurations Application Configuration Sql Application Configuration Input Input Starting Position Configuration The point at which the application starts processing records from the streaming source.
- Kinesis
Firehose ApplicationInput Application Configuration Sql Application Configuration Input Kinesis Firehose Input If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
- Kinesis
Streams ApplicationInput Application Configuration Sql Application Configuration Input Kinesis Streams Input If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
- input
Schema ApplicationApplication Configuration Sql Application Configuration Input Input Schema 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 String The name prefix to use when creating an in-application stream.
- in
App List<String>Stream Names - input
Id String - input
Parallelism ApplicationApplication Configuration Sql Application Configuration Input Input Parallelism Describes the number of in-application streams to create.
- input
Processing ApplicationConfiguration Application Configuration Sql Application Configuration Input Input Processing Configuration 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 List<ApplicationPosition Configurations Application Configuration Sql Application Configuration Input Input Starting Position Configuration> The point at which the application starts processing records from the streaming source.
- kinesis
Firehose ApplicationInput Application Configuration Sql Application Configuration Input Kinesis Firehose Input If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
- kinesis
Streams ApplicationInput Application Configuration Sql Application Configuration Input Kinesis Streams Input If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
- input
Schema ApplicationApplication Configuration Sql Application Configuration Input Input Schema 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 string The name prefix to use when creating an in-application stream.
- in
App string[]Stream Names - input
Id string - input
Parallelism ApplicationApplication Configuration Sql Application Configuration Input Input Parallelism Describes the number of in-application streams to create.
- input
Processing ApplicationConfiguration Application Configuration Sql Application Configuration Input Input Processing Configuration 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 ApplicationPosition Configurations Application Configuration Sql Application Configuration Input Input Starting Position Configuration[] The point at which the application starts processing records from the streaming source.
- kinesis
Firehose ApplicationInput Application Configuration Sql Application Configuration Input Kinesis Firehose Input If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
- kinesis
Streams ApplicationInput Application Configuration Sql Application Configuration Input Kinesis Streams Input If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
- input_
schema ApplicationApplication Configuration Sql Application Configuration Input Input Schema 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_ Sequence[str]stream_ names - input_
id str - input_
parallelism ApplicationApplication Configuration Sql Application Configuration Input Input Parallelism Describes the number of in-application streams to create.
- input_
processing_ Applicationconfiguration Application Configuration Sql Application Configuration Input Input Processing Configuration 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_ Sequence[Applicationposition_ configurations Application Configuration Sql Application Configuration Input Input Starting Position Configuration] The point at which the application starts processing records from the streaming source.
- kinesis_
firehose_ Applicationinput Application Configuration Sql Application Configuration Input Kinesis Firehose Input If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
- kinesis_
streams_ Applicationinput Application Configuration Sql Application Configuration Input Kinesis Streams Input If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
- input
Schema 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.
- name
Prefix String The name prefix to use when creating an in-application stream.
- in
App List<String>Stream Names - input
Id String - input
Parallelism Property Map Describes the number of in-application streams to create.
- input
Processing Property MapConfiguration 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 List<Property Map>Position Configurations The point at which the application starts processing records from the streaming source.
- kinesis
Firehose Property MapInput If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
- kinesis
Streams Property MapInput 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
- Input
Lambda ApplicationProcessor Application Configuration Sql Application Configuration Input Input Processing Configuration Input Lambda Processor Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
- Input
Lambda ApplicationProcessor Application Configuration Sql Application Configuration Input Input Processing Configuration Input Lambda Processor Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
- input
Lambda ApplicationProcessor Application Configuration Sql Application Configuration Input Input Processing Configuration Input Lambda Processor Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
- input
Lambda ApplicationProcessor Application Configuration Sql Application Configuration Input Input Processing Configuration Input Lambda Processor Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
- input_
lambda_ Applicationprocessor Application Configuration Sql Application Configuration Input Input Processing Configuration Input Lambda Processor Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
- input
Lambda Property MapProcessor Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputProcessingConfigurationInputLambdaProcessor
- Resource
Arn string The ARN of the Lambda function that operates on records in the stream.
- Resource
Arn string The ARN of the Lambda function that operates on records in the stream.
- resource
Arn String The ARN of the Lambda function that operates on records in the stream.
- resource
Arn 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.
- resource
Arn String The ARN of the Lambda function that operates on records in the stream.
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchema
- Record
Columns List<ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Column> Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- Record
Format ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format Specifies the format of the records on the streaming source.
- Record
Encoding string Specifies the encoding of the records in the streaming source. For example,
UTF-8.
- Record
Columns []ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Column Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- Record
Format ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format Specifies the format of the records on the streaming source.
- Record
Encoding string Specifies the encoding of the records in the streaming source. For example,
UTF-8.
- record
Columns List<ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Column> Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- record
Format ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format Specifies the format of the records on the streaming source.
- record
Encoding String Specifies the encoding of the records in the streaming source. For example,
UTF-8.
- record
Columns ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Column[] Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- record
Format ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format Specifies the format of the records on the streaming source.
- record
Encoding string Specifies the encoding of the records in the streaming source. For example,
UTF-8.
- record_
columns Sequence[ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Column] Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- record_
format ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format 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.
- record
Columns List<Property Map> Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- record
Format Property Map Specifies the format of the records on the streaming source.
- record
Encoding String Specifies the encoding of the records in the streaming source. For example,
UTF-8.
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumn
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormat
- Mapping
Parameters ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters 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 stringType The type of record format. Valid values:
CSV,JSON.
- Mapping
Parameters ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters 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 stringType The type of record format. Valid values:
CSV,JSON.
- mapping
Parameters ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters 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 StringType The type of record format. Valid values:
CSV,JSON.
- mapping
Parameters ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters 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 stringType The type of record format. Valid values:
CSV,JSON.
- mapping_
parameters ApplicationApplication Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters 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_ strtype The type of record format. Valid values:
CSV,JSON.
- mapping
Parameters 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.
- record
Format StringType The type of record format. Valid values:
CSV,JSON.
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParameters
- Csv
Mapping ApplicationParameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- Json
Mapping ApplicationParameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- Csv
Mapping ApplicationParameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- Json
Mapping ApplicationParameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- csv
Mapping ApplicationParameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- json
Mapping ApplicationParameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- csv
Mapping ApplicationParameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- json
Mapping ApplicationParameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- csv_
mapping_ Applicationparameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- json_
mapping_ Applicationparameters Application Configuration Sql Application Configuration Input Input Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- csv
Mapping Property MapParameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- json
Mapping Property MapParameters Provides additional mapping information when JSON is the record format on the streaming source.
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParameters
- Record
Column stringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- Record
Row stringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- Record
Column stringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- Record
Row stringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- record
Column StringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- record
Row StringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- record
Column stringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- record
Row stringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- record_
column_ strdelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- record_
row_ strdelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- record
Column StringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- record
Row StringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersJsonMappingParameters
- Record
Row stringPath The path to the top-level parent that contains the records.
- Record
Row stringPath The path to the top-level parent that contains the records.
- record
Row StringPath The path to the top-level parent that contains the records.
- record
Row stringPath The path to the top-level parent that contains the records.
- record_
row_ strpath The path to the top-level parent that contains the records.
- record
Row StringPath The path to the top-level parent that contains the records.
ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputStartingPositionConfiguration
- Input
Starting stringPosition The starting position on the stream. Valid values:
LAST_STOPPED_POINT,NOW,TRIM_HORIZON.
- Input
Starting stringPosition The starting position on the stream. Valid values:
LAST_STOPPED_POINT,NOW,TRIM_HORIZON.
- input
Starting StringPosition The starting position on the stream. Valid values:
LAST_STOPPED_POINT,NOW,TRIM_HORIZON.
- input
Starting stringPosition The starting position on the stream. Valid values:
LAST_STOPPED_POINT,NOW,TRIM_HORIZON.
- input_
starting_ strposition The starting position on the stream. Valid values:
LAST_STOPPED_POINT,NOW,TRIM_HORIZON.
- input
Starting StringPosition The starting position on the stream. Valid values:
LAST_STOPPED_POINT,NOW,TRIM_HORIZON.
ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisFirehoseInput
- Resource
Arn string The ARN of the delivery stream.
- Resource
Arn string The ARN of the delivery stream.
- resource
Arn String The ARN of the delivery stream.
- resource
Arn string The ARN of the delivery stream.
- resource_
arn str The ARN of the delivery stream.
- resource
Arn String The ARN of the delivery stream.
ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInput
- Resource
Arn string The ARN of the input Kinesis data stream to read.
- Resource
Arn string The ARN of the input Kinesis data stream to read.
- resource
Arn String The ARN of the input Kinesis data stream to read.
- resource
Arn string The ARN of the input Kinesis data stream to read.
- resource_
arn str The ARN of the input Kinesis data stream to read.
- resource
Arn String The ARN of the input Kinesis data stream to read.
ApplicationApplicationConfigurationSqlApplicationConfigurationOutput
- Destination
Schema ApplicationApplication Configuration Sql Application Configuration Output Destination Schema Describes the data format when records are written to the destination.
- Name string
The name of the in-application stream.
- Kinesis
Firehose ApplicationOutput Application Configuration Sql Application Configuration Output Kinesis Firehose Output Identifies a Kinesis Data Firehose delivery stream as the destination.
- Kinesis
Streams ApplicationOutput Application Configuration Sql Application Configuration Output Kinesis Streams Output Identifies a Kinesis data stream as the destination.
- Lambda
Output ApplicationApplication Configuration Sql Application Configuration Output Lambda Output Identifies a Lambda function as the destination.
- Output
Id string
- Destination
Schema ApplicationApplication Configuration Sql Application Configuration Output Destination Schema Describes the data format when records are written to the destination.
- Name string
The name of the in-application stream.
- Kinesis
Firehose ApplicationOutput Application Configuration Sql Application Configuration Output Kinesis Firehose Output Identifies a Kinesis Data Firehose delivery stream as the destination.
- Kinesis
Streams ApplicationOutput Application Configuration Sql Application Configuration Output Kinesis Streams Output Identifies a Kinesis data stream as the destination.
- Lambda
Output ApplicationApplication Configuration Sql Application Configuration Output Lambda Output Identifies a Lambda function as the destination.
- Output
Id string
- destination
Schema ApplicationApplication Configuration Sql Application Configuration Output Destination Schema Describes the data format when records are written to the destination.
- name String
The name of the in-application stream.
- kinesis
Firehose ApplicationOutput Application Configuration Sql Application Configuration Output Kinesis Firehose Output Identifies a Kinesis Data Firehose delivery stream as the destination.
- kinesis
Streams ApplicationOutput Application Configuration Sql Application Configuration Output Kinesis Streams Output Identifies a Kinesis data stream as the destination.
- lambda
Output ApplicationApplication Configuration Sql Application Configuration Output Lambda Output Identifies a Lambda function as the destination.
- output
Id String
- destination
Schema ApplicationApplication Configuration Sql Application Configuration Output Destination Schema Describes the data format when records are written to the destination.
- name string
The name of the in-application stream.
- kinesis
Firehose ApplicationOutput Application Configuration Sql Application Configuration Output Kinesis Firehose Output Identifies a Kinesis Data Firehose delivery stream as the destination.
- kinesis
Streams ApplicationOutput Application Configuration Sql Application Configuration Output Kinesis Streams Output Identifies a Kinesis data stream as the destination.
- lambda
Output ApplicationApplication Configuration Sql Application Configuration Output Lambda Output Identifies a Lambda function as the destination.
- output
Id string
- destination_
schema ApplicationApplication Configuration Sql Application Configuration Output Destination Schema Describes the data format when records are written to the destination.
- name str
The name of the in-application stream.
- kinesis_
firehose_ Applicationoutput Application Configuration Sql Application Configuration Output Kinesis Firehose Output Identifies a Kinesis Data Firehose delivery stream as the destination.
- kinesis_
streams_ Applicationoutput Application Configuration Sql Application Configuration Output Kinesis Streams Output Identifies a Kinesis data stream as the destination.
- lambda_
output ApplicationApplication Configuration Sql Application Configuration Output Lambda Output Identifies a Lambda function as the destination.
- output_
id str
- destination
Schema Property Map Describes the data format when records are written to the destination.
- name String
The name of the in-application stream.
- kinesis
Firehose Property MapOutput Identifies a Kinesis Data Firehose delivery stream as the destination.
- kinesis
Streams Property MapOutput Identifies a Kinesis data stream as the destination.
- lambda
Output Property Map Identifies a Lambda function as the destination.
- output
Id String
ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchema
- Record
Format stringType Specifies the format of the records on the output stream. Valid values:
CSV,JSON.
- Record
Format stringType Specifies the format of the records on the output stream. Valid values:
CSV,JSON.
- record
Format StringType Specifies the format of the records on the output stream. Valid values:
CSV,JSON.
- record
Format stringType Specifies the format of the records on the output stream. Valid values:
CSV,JSON.
- record_
format_ strtype Specifies the format of the records on the output stream. Valid values:
CSV,JSON.
- record
Format StringType Specifies the format of the records on the output stream. Valid values:
CSV,JSON.
ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutput
- Resource
Arn string The ARN of the destination delivery stream to write to.
- Resource
Arn string The ARN of the destination delivery stream to write to.
- resource
Arn String The ARN of the destination delivery stream to write to.
- resource
Arn string The ARN of the destination delivery stream to write to.
- resource_
arn str The ARN of the destination delivery stream to write to.
- resource
Arn String The ARN of the destination delivery stream to write to.
ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisStreamsOutput
- Resource
Arn string The ARN of the destination Kinesis data stream to write to.
- Resource
Arn string The ARN of the destination Kinesis data stream to write to.
- resource
Arn String The ARN of the destination Kinesis data stream to write to.
- resource
Arn 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.
- resource
Arn String The ARN of the destination Kinesis data stream to write to.
ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutput
- Resource
Arn string The ARN of the destination Lambda function to write to.
- Resource
Arn string The ARN of the destination Lambda function to write to.
- resource
Arn String The ARN of the destination Lambda function to write to.
- resource
Arn string The ARN of the destination Lambda function to write to.
- resource_
arn str The ARN of the destination Lambda function to write to.
- resource
Arn String The ARN of the destination Lambda function to write to.
ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSource
- Reference
Schema ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema 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.
- S3Reference
Data ApplicationSource Application Configuration Sql Application Configuration Reference Data Source S3Reference Data Source Identifies the S3 bucket and object that contains the reference data.
- Table
Name string The name of the in-application table to create.
- Reference
Id string
- Reference
Schema ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema 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.
- S3Reference
Data ApplicationSource Application Configuration Sql Application Configuration Reference Data Source S3Reference Data Source Identifies the S3 bucket and object that contains the reference data.
- Table
Name string The name of the in-application table to create.
- Reference
Id string
- reference
Schema ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema 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.
- s3Reference
Data ApplicationSource Application Configuration Sql Application Configuration Reference Data Source S3Reference Data Source Identifies the S3 bucket and object that contains the reference data.
- table
Name String The name of the in-application table to create.
- reference
Id String
- reference
Schema ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema 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.
- s3Reference
Data ApplicationSource Application Configuration Sql Application Configuration Reference Data Source S3Reference Data Source Identifies the S3 bucket and object that contains the reference data.
- table
Name string The name of the in-application table to create.
- reference
Id string
- reference_
schema ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema 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_ Applicationdata_ source Application Configuration Sql Application Configuration Reference Data Source S3Reference Data Source 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
- reference
Schema 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.
- s3Reference
Data Property MapSource Identifies the S3 bucket and object that contains the reference data.
- table
Name String The name of the in-application table to create.
- reference
Id String
ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchema
- Record
Columns List<ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Column> Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- Record
Format ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Specifies the format of the records on the streaming source.
- Record
Encoding string Specifies the encoding of the records in the streaming source. For example,
UTF-8.
- Record
Columns []ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Column Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- Record
Format ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Specifies the format of the records on the streaming source.
- Record
Encoding string Specifies the encoding of the records in the streaming source. For example,
UTF-8.
- record
Columns List<ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Column> Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- record
Format ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Specifies the format of the records on the streaming source.
- record
Encoding String Specifies the encoding of the records in the streaming source. For example,
UTF-8.
- record
Columns ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Column[] Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- record
Format ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Specifies the format of the records on the streaming source.
- record
Encoding string Specifies the encoding of the records in the streaming source. For example,
UTF-8.
- record_
columns Sequence[ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Column] Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- record_
format ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format 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.
- record
Columns List<Property Map> Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
- record
Format Property Map Specifies the format of the records on the streaming source.
- record
Encoding String Specifies the encoding of the records in the streaming source. For example,
UTF-8.
ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumn
ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormat
- Mapping
Parameters ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters 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 stringType The type of record format. Valid values:
CSV,JSON.
- Mapping
Parameters ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters 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 stringType The type of record format. Valid values:
CSV,JSON.
- mapping
Parameters ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters 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 StringType The type of record format. Valid values:
CSV,JSON.
- mapping
Parameters ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters 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 stringType The type of record format. Valid values:
CSV,JSON.
- mapping_
parameters ApplicationApplication Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters 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_ strtype The type of record format. Valid values:
CSV,JSON.
- mapping
Parameters 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.
- record
Format StringType The type of record format. Valid values:
CSV,JSON.
ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParameters
- Csv
Mapping ApplicationParameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- Json
Mapping ApplicationParameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- Csv
Mapping ApplicationParameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- Json
Mapping ApplicationParameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- csv
Mapping ApplicationParameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- json
Mapping ApplicationParameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- csv
Mapping ApplicationParameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- json
Mapping ApplicationParameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- csv_
mapping_ Applicationparameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Csv Mapping Parameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- json_
mapping_ Applicationparameters Application Configuration Sql Application Configuration Reference Data Source Reference Schema Record Format Mapping Parameters Json Mapping Parameters Provides additional mapping information when JSON is the record format on the streaming source.
- csv
Mapping Property MapParameters Provides additional mapping information when the record format uses delimiters (for example, CSV).
- json
Mapping Property MapParameters Provides additional mapping information when JSON is the record format on the streaming source.
ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersCsvMappingParameters
- Record
Column stringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- Record
Row stringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- Record
Column stringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- Record
Row stringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- record
Column StringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- record
Row StringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- record
Column stringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- record
Row stringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- record_
column_ strdelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- record_
row_ strdelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
- record
Column StringDelimiter The column delimiter. For example, in a CSV format, a comma (
,) is the typical column delimiter.- record
Row StringDelimiter The row delimiter. For example, in a CSV format,
\nis the typical row delimiter.
ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParameters
- Record
Row stringPath The path to the top-level parent that contains the records.
- Record
Row stringPath The path to the top-level parent that contains the records.
- record
Row StringPath The path to the top-level parent that contains the records.
- record
Row stringPath The path to the top-level parent that contains the records.
- record_
row_ strpath The path to the top-level parent that contains the records.
- record
Row StringPath The path to the top-level parent that contains the records.
ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSource
- 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.
ApplicationApplicationConfigurationVpcConfiguration
- Security
Group List<string>Ids The Security Group IDs used by the VPC configuration.
- Subnet
Ids List<string> The Subnet IDs used by the VPC configuration.
- Vpc
Configuration stringId - Vpc
Id string
- Security
Group []stringIds The Security Group IDs used by the VPC configuration.
- Subnet
Ids []string The Subnet IDs used by the VPC configuration.
- Vpc
Configuration stringId - Vpc
Id string
- security
Group List<String>Ids The Security Group IDs used by the VPC configuration.
- subnet
Ids List<String> The Subnet IDs used by the VPC configuration.
- vpc
Configuration StringId - vpc
Id String
- security
Group string[]Ids The Security Group IDs used by the VPC configuration.
- subnet
Ids string[] The Subnet IDs used by the VPC configuration.
- vpc
Configuration stringId - vpc
Id string
- security_
group_ Sequence[str]ids The Security Group IDs used by the VPC configuration.
- subnet_
ids Sequence[str] The Subnet IDs used by the VPC configuration.
- vpc_
configuration_ strid - vpc_
id str
- security
Group List<String>Ids The Security Group IDs used by the VPC configuration.
- subnet
Ids List<String> The Subnet IDs used by the VPC configuration.
- vpc
Configuration StringId - vpc
Id String
ApplicationCloudwatchLoggingOptions
- Log
Stream stringArn The ARN of the CloudWatch log stream to receive application messages.
- Cloudwatch
Logging stringOption Id
- Log
Stream stringArn The ARN of the CloudWatch log stream to receive application messages.
- Cloudwatch
Logging stringOption Id
- log
Stream StringArn The ARN of the CloudWatch log stream to receive application messages.
- cloudwatch
Logging StringOption Id
- log
Stream stringArn The ARN of the CloudWatch log stream to receive application messages.
- cloudwatch
Logging stringOption Id
- log_
stream_ strarn The ARN of the CloudWatch log stream to receive application messages.
- cloudwatch_
logging_ stroption_ id
- log
Stream StringArn The ARN of the CloudWatch log stream to receive application messages.
- cloudwatch
Logging StringOption Id
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
- AWS Classic pulumi/pulumi-aws
- License
- Apache-2.0
- Notes
This Pulumi package is based on the
awsTerraform Provider.