pulumi-aws-native-kotlin/com.pulumi.awsnative.kinesisanalyticsv2.kotlin.inputs

Package-level declarations

Types

data class ApplicationCatalogConfigurationArgs(val glueDataCatalogConfiguration: Output<ApplicationGlueDataCatalogConfigurationArgs>? = null) : ConvertibleToJava<ApplicationCatalogConfigurationArgs>

The configuration parameters for the default Amazon Glue database. You use this database for SQL queries that you write in a Kinesis Data Analytics Studio notebook.

ApplicationCatalogConfigurationArgsBuilder

class ApplicationCatalogConfigurationArgsBuilder

Builder for ApplicationCatalogConfigurationArgs.

ApplicationCheckpointConfigurationArgs

data class ApplicationCheckpointConfigurationArgs(val checkpointInterval: Output<Int>? = null, val checkpointingEnabled: Output<Boolean>? = null, val configurationType: Output<ApplicationCheckpointConfigurationConfigurationType>, val minPauseBetweenCheckpoints: Output<Int>? = null) : ConvertibleToJava<ApplicationCheckpointConfigurationArgs>

Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.

ApplicationCheckpointConfigurationArgsBuilder

class ApplicationCheckpointConfigurationArgsBuilder

Builder for ApplicationCheckpointConfigurationArgs.

ApplicationCodeConfigurationArgs

data class ApplicationCodeConfigurationArgs(val codeContent: Output<ApplicationCodeContentArgs>, val codeContentType: Output<ApplicationCodeConfigurationCodeContentType>) : ConvertibleToJava<ApplicationCodeConfigurationArgs>

Describes code configuration for an application.

ApplicationCodeConfigurationArgsBuilder

class ApplicationCodeConfigurationArgsBuilder

Builder for ApplicationCodeConfigurationArgs.

ApplicationCodeContentArgs

data class ApplicationCodeContentArgs(val s3ContentLocation: Output<ApplicationS3ContentLocationArgs>? = null, val textContent: Output<String>? = null, val zipFileContent: Output<String>? = null) : ConvertibleToJava<ApplicationCodeContentArgs>

Specifies either the application code, or the location of the application code, for a Flink-based Kinesis Data Analytics application.

ApplicationCodeContentArgsBuilder

class ApplicationCodeContentArgsBuilder

Builder for ApplicationCodeContentArgs.

ApplicationConfigurationArgs

data class ApplicationConfigurationArgs(val applicationCodeConfiguration: Output<ApplicationCodeConfigurationArgs>? = null, val applicationSnapshotConfiguration: Output<ApplicationSnapshotConfigurationArgs>? = null, val applicationSystemRollbackConfiguration: Output<ApplicationSystemRollbackConfigurationArgs>? = null, val environmentProperties: Output<ApplicationEnvironmentPropertiesArgs>? = null, val flinkApplicationConfiguration: Output<ApplicationFlinkApplicationConfigurationArgs>? = null, val sqlApplicationConfiguration: Output<ApplicationSqlApplicationConfigurationArgs>? = null, val vpcConfigurations: Output<List<ApplicationVpcConfigurationArgs>>? = null, val zeppelinApplicationConfiguration: Output<ApplicationZeppelinApplicationConfigurationArgs>? = null) : ConvertibleToJava<ApplicationConfigurationArgs>

Specifies the creation parameters for a Kinesis Data Analytics application.

ApplicationConfigurationArgsBuilder

class ApplicationConfigurationArgsBuilder

Builder for ApplicationConfigurationArgs.

ApplicationCsvMappingParametersArgs

data class ApplicationCsvMappingParametersArgs(val recordColumnDelimiter: Output<String>, val recordRowDelimiter: Output<String>) : ConvertibleToJava<ApplicationCsvMappingParametersArgs>

For a SQL-based Kinesis Data Analytics application, provides additional mapping information when the record format uses delimiters, such as CSV. For example, the following sample records use CSV format, where the records use the '\n' as the row delimiter and a comma (",") as the column delimiter: "name1", "address1" "name2", "address2"

ApplicationCsvMappingParametersArgsBuilder

class ApplicationCsvMappingParametersArgsBuilder

Builder for ApplicationCsvMappingParametersArgs.

ApplicationCustomArtifactConfigurationArgs

data class ApplicationCustomArtifactConfigurationArgs(val artifactType: Output<ApplicationCustomArtifactConfigurationArtifactType>, val mavenReference: Output<ApplicationMavenReferenceArgs>? = null, val s3ContentLocation: Output<ApplicationS3ContentLocationArgs>? = null) : ConvertibleToJava<ApplicationCustomArtifactConfigurationArgs>

The configuration of connectors and user-defined functions.

ApplicationCustomArtifactConfigurationArgsBuilder

class ApplicationCustomArtifactConfigurationArgsBuilder

Builder for ApplicationCustomArtifactConfigurationArgs.

ApplicationDeployAsApplicationConfigurationArgs

data class ApplicationDeployAsApplicationConfigurationArgs(val s3ContentLocation: Output<ApplicationS3ContentBaseLocationArgs>) : ConvertibleToJava<ApplicationDeployAsApplicationConfigurationArgs>

The information required to deploy a Kinesis Data Analytics Studio notebook as an application with durable state.

ApplicationDeployAsApplicationConfigurationArgsBuilder

class ApplicationDeployAsApplicationConfigurationArgsBuilder

Builder for ApplicationDeployAsApplicationConfigurationArgs.

ApplicationEnvironmentPropertiesArgs

data class ApplicationEnvironmentPropertiesArgs(val propertyGroups: Output<List<ApplicationPropertyGroupArgs>>? = null) : ConvertibleToJava<ApplicationEnvironmentPropertiesArgs>

Describes execution properties for a Flink-based Kinesis Data Analytics application.

ApplicationEnvironmentPropertiesArgsBuilder

class ApplicationEnvironmentPropertiesArgsBuilder

Builder for ApplicationEnvironmentPropertiesArgs.

ApplicationFlinkApplicationConfigurationArgs

data class ApplicationFlinkApplicationConfigurationArgs(val checkpointConfiguration: Output<ApplicationCheckpointConfigurationArgs>? = null, val monitoringConfiguration: Output<ApplicationMonitoringConfigurationArgs>? = null, val parallelismConfiguration: Output<ApplicationParallelismConfigurationArgs>? = null) : ConvertibleToJava<ApplicationFlinkApplicationConfigurationArgs>

Describes configuration parameters for a Flink-based Kinesis Data Analytics application or a Studio notebook.

ApplicationFlinkApplicationConfigurationArgsBuilder

class ApplicationFlinkApplicationConfigurationArgsBuilder

Builder for ApplicationFlinkApplicationConfigurationArgs.

ApplicationFlinkRunConfigurationArgs

data class ApplicationFlinkRunConfigurationArgs(val allowNonRestoredState: Output<Boolean>? = null) : ConvertibleToJava<ApplicationFlinkRunConfigurationArgs>

Describes the starting parameters for a Flink-based Kinesis Data Analytics application.

ApplicationFlinkRunConfigurationArgsBuilder

class ApplicationFlinkRunConfigurationArgsBuilder

Builder for ApplicationFlinkRunConfigurationArgs.

ApplicationGlueDataCatalogConfigurationArgs

data class ApplicationGlueDataCatalogConfigurationArgs(val databaseArn: Output<String>? = null) : ConvertibleToJava<ApplicationGlueDataCatalogConfigurationArgs>

The configuration of the Glue Data Catalog that you use for Apache Flink SQL queries and table API transforms that you write in an application.

ApplicationGlueDataCatalogConfigurationArgsBuilder

class ApplicationGlueDataCatalogConfigurationArgsBuilder

Builder for ApplicationGlueDataCatalogConfigurationArgs.

ApplicationInputArgs

data class ApplicationInputArgs(val inputParallelism: Output<ApplicationInputParallelismArgs>? = null, val inputProcessingConfiguration: Output<ApplicationInputProcessingConfigurationArgs>? = null, val inputSchema: Output<ApplicationInputSchemaArgs>, val kinesisFirehoseInput: Output<ApplicationKinesisFirehoseInputArgs>? = null, val kinesisStreamsInput: Output<ApplicationKinesisStreamsInputArgs>? = null, val namePrefix: Output<String>) : ConvertibleToJava<ApplicationInputArgs>

When you configure the application input for a SQL-based Kinesis Data Analytics application, you specify the streaming source, the in-application stream name that is created, and the mapping between the two.

ApplicationInputArgsBuilder

class ApplicationInputArgsBuilder

Builder for ApplicationInputArgs.

ApplicationInputLambdaProcessorArgs

data class ApplicationInputLambdaProcessorArgs(val resourceArn: Output<String>) : ConvertibleToJava<ApplicationInputLambdaProcessorArgs>

An object that contains the Amazon Resource Name (ARN) of the Amazon Lambda function that is used to preprocess records in the stream in a SQL-based Kinesis Data Analytics application.

ApplicationInputLambdaProcessorArgsBuilder

class ApplicationInputLambdaProcessorArgsBuilder

Builder for ApplicationInputLambdaProcessorArgs.

ApplicationInputParallelismArgs

data class ApplicationInputParallelismArgs(val count: Output<Int>? = null) : ConvertibleToJava<ApplicationInputParallelismArgs>

For a SQL-based Kinesis Data Analytics application, describes the number of in-application streams to create for a given streaming source.

ApplicationInputParallelismArgsBuilder

class ApplicationInputParallelismArgsBuilder

Builder for ApplicationInputParallelismArgs.

ApplicationInputProcessingConfigurationArgs

data class ApplicationInputProcessingConfigurationArgs(val inputLambdaProcessor: Output<ApplicationInputLambdaProcessorArgs>? = null) : ConvertibleToJava<ApplicationInputProcessingConfigurationArgs>

For an SQL-based Amazon Kinesis Data Analytics application, describes a processor that is used to preprocess the records in the stream before being processed by your application code. Currently, the only input processor available is Amazon Lambda.

ApplicationInputProcessingConfigurationArgsBuilder

class ApplicationInputProcessingConfigurationArgsBuilder

Builder for ApplicationInputProcessingConfigurationArgs.

ApplicationInputSchemaArgs

data class ApplicationInputSchemaArgs(val recordColumns: Output<List<ApplicationRecordColumnArgs>>, val recordEncoding: Output<ApplicationInputSchemaRecordEncoding>? = null, val recordFormat: Output<ApplicationRecordFormatArgs>) : ConvertibleToJava<ApplicationInputSchemaArgs>

For a SQL-based Kinesis Data Analytics application, 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.

ApplicationInputSchemaArgsBuilder

class ApplicationInputSchemaArgsBuilder

Builder for ApplicationInputSchemaArgs.

ApplicationJsonMappingParametersArgs

data class ApplicationJsonMappingParametersArgs(val recordRowPath: Output<String>) : ConvertibleToJava<ApplicationJsonMappingParametersArgs>

For a SQL-based Kinesis Data Analytics application, provides additional mapping information when JSON is the record format on the streaming source.

ApplicationJsonMappingParametersArgsBuilder

class ApplicationJsonMappingParametersArgsBuilder

Builder for ApplicationJsonMappingParametersArgs.

ApplicationKinesisFirehoseInputArgs

data class ApplicationKinesisFirehoseInputArgs(val resourceArn: Output<String>) : ConvertibleToJava<ApplicationKinesisFirehoseInputArgs>

For a SQL-based Kinesis Data Analytics application, identifies a Kinesis Data Firehose delivery stream as the streaming source. You provide the delivery stream's Amazon Resource Name (ARN).

ApplicationKinesisFirehoseInputArgsBuilder

class ApplicationKinesisFirehoseInputArgsBuilder

Builder for ApplicationKinesisFirehoseInputArgs.

ApplicationKinesisStreamsInputArgs

data class ApplicationKinesisStreamsInputArgs(val resourceArn: Output<String>) : ConvertibleToJava<ApplicationKinesisStreamsInputArgs>

Identifies a Kinesis data stream as the streaming source. You provide the stream's Amazon Resource Name (ARN).

ApplicationKinesisStreamsInputArgsBuilder

class ApplicationKinesisStreamsInputArgsBuilder

Builder for ApplicationKinesisStreamsInputArgs.

ApplicationMaintenanceConfigurationArgs

data class ApplicationMaintenanceConfigurationArgs(val applicationMaintenanceWindowStartTime: Output<String>) : ConvertibleToJava<ApplicationMaintenanceConfigurationArgs>

Describes the maintenance configuration for the application.

ApplicationMaintenanceConfigurationArgsBuilder

class ApplicationMaintenanceConfigurationArgsBuilder

Builder for ApplicationMaintenanceConfigurationArgs.

ApplicationMappingParametersArgs

data class ApplicationMappingParametersArgs(val csvMappingParameters: Output<ApplicationCsvMappingParametersArgs>? = null, val jsonMappingParameters: Output<ApplicationJsonMappingParametersArgs>? = null) : ConvertibleToJava<ApplicationMappingParametersArgs>

When you configure a SQL-based Kinesis Data Analytics application's input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

ApplicationMappingParametersArgsBuilder

class ApplicationMappingParametersArgsBuilder

Builder for ApplicationMappingParametersArgs.

ApplicationMavenReferenceArgs

data class ApplicationMavenReferenceArgs(val artifactId: Output<String>, val groupId: Output<String>, val version: Output<String>) : ConvertibleToJava<ApplicationMavenReferenceArgs>

The information required to specify a Maven reference. You can use Maven references to specify dependency JAR files.

ApplicationMavenReferenceArgsBuilder

class ApplicationMavenReferenceArgsBuilder

Builder for ApplicationMavenReferenceArgs.

ApplicationMonitoringConfigurationArgs

data class ApplicationMonitoringConfigurationArgs(val configurationType: Output<ApplicationMonitoringConfigurationConfigurationType>, val logLevel: Output<ApplicationMonitoringConfigurationLogLevel>? = null, val metricsLevel: Output<ApplicationMonitoringConfigurationMetricsLevel>? = null) : ConvertibleToJava<ApplicationMonitoringConfigurationArgs>

Describes configuration parameters for Amazon CloudWatch logging for a Java-based Kinesis Data Analytics application. For more information about CloudWatch logging, see Monitoring.

ApplicationMonitoringConfigurationArgsBuilder

class ApplicationMonitoringConfigurationArgsBuilder

Builder for ApplicationMonitoringConfigurationArgs.

ApplicationParallelismConfigurationArgs

data class ApplicationParallelismConfigurationArgs(val autoScalingEnabled: Output<Boolean>? = null, val configurationType: Output<ApplicationParallelismConfigurationConfigurationType>, val parallelism: Output<Int>? = null, val parallelismPerKpu: Output<Int>? = null) : ConvertibleToJava<ApplicationParallelismConfigurationArgs>

Describes parameters for how a Flink-based Kinesis Data Analytics application executes multiple tasks simultaneously. For more information about parallelism, see Parallel Execution in the Apache Flink Documentation

ApplicationParallelismConfigurationArgsBuilder

class ApplicationParallelismConfigurationArgsBuilder

Builder for ApplicationParallelismConfigurationArgs.

ApplicationPropertyGroupArgs

data class ApplicationPropertyGroupArgs(val propertyGroupId: Output<String>? = null, val propertyMap: Output<Map<String, String>>? = null) : ConvertibleToJava<ApplicationPropertyGroupArgs>

Property key-value pairs passed into an application.

ApplicationPropertyGroupArgsBuilder

class ApplicationPropertyGroupArgsBuilder

Builder for ApplicationPropertyGroupArgs.

ApplicationRecordColumnArgs

data class ApplicationRecordColumnArgs(val mapping: Output<String>? = null, val name: Output<String>, val sqlType: Output<String>) : ConvertibleToJava<ApplicationRecordColumnArgs>

For a SQL-based Kinesis Data Analytics application, describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream. Also used to describe the format of the reference data source.

ApplicationRecordColumnArgsBuilder

class ApplicationRecordColumnArgsBuilder

Builder for ApplicationRecordColumnArgs.

ApplicationRecordFormatArgs

data class ApplicationRecordFormatArgs(val mappingParameters: Output<ApplicationMappingParametersArgs>? = null, val recordFormatType: Output<ApplicationRecordFormatRecordFormatType>) : ConvertibleToJava<ApplicationRecordFormatArgs>

For a SQL-based Kinesis Data Analytics application, describes the record format and relevant mapping information that should be applied to schematize the records on the stream.

ApplicationRecordFormatArgsBuilder

class ApplicationRecordFormatArgsBuilder

Builder for ApplicationRecordFormatArgs.

ApplicationRestoreConfigurationArgs

data class ApplicationRestoreConfigurationArgs(val applicationRestoreType: Output<ApplicationRestoreConfigurationApplicationRestoreType>, val snapshotName: Output<String>? = null) : ConvertibleToJava<ApplicationRestoreConfigurationArgs>

Describes the restore behavior of a restarting application.

ApplicationRestoreConfigurationArgsBuilder

class ApplicationRestoreConfigurationArgsBuilder

Builder for ApplicationRestoreConfigurationArgs.

ApplicationRunConfigurationArgs

data class ApplicationRunConfigurationArgs(val applicationRestoreConfiguration: Output<ApplicationRestoreConfigurationArgs>? = null, val flinkRunConfiguration: Output<ApplicationFlinkRunConfigurationArgs>? = null) : ConvertibleToJava<ApplicationRunConfigurationArgs>

Identifies the run configuration (start parameters) of a Kinesis Data Analytics application. This section is evaluated only on stack updates for applications in running RUNNING state and has no effect during manual application start.

ApplicationRunConfigurationArgsBuilder

class ApplicationRunConfigurationArgsBuilder

Builder for ApplicationRunConfigurationArgs.

ApplicationS3ContentBaseLocationArgs

data class ApplicationS3ContentBaseLocationArgs(val basePath: Output<String>? = null, val bucketArn: Output<String>) : ConvertibleToJava<ApplicationS3ContentBaseLocationArgs>

The base location of the Amazon Data Analytics application.

ApplicationS3ContentBaseLocationArgsBuilder

class ApplicationS3ContentBaseLocationArgsBuilder

Builder for ApplicationS3ContentBaseLocationArgs.

ApplicationS3ContentLocationArgs

data class ApplicationS3ContentLocationArgs(val bucketArn: Output<String>, val fileKey: Output<String>, val objectVersion: Output<String>? = null) : ConvertibleToJava<ApplicationS3ContentLocationArgs>

The location of an application or a custom artifact.

ApplicationS3ContentLocationArgsBuilder

class ApplicationS3ContentLocationArgsBuilder

Builder for ApplicationS3ContentLocationArgs.

ApplicationSnapshotConfigurationArgs

data class ApplicationSnapshotConfigurationArgs(val snapshotsEnabled: Output<Boolean>) : ConvertibleToJava<ApplicationSnapshotConfigurationArgs>

Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.

ApplicationSnapshotConfigurationArgsBuilder

class ApplicationSnapshotConfigurationArgsBuilder

Builder for ApplicationSnapshotConfigurationArgs.

ApplicationSqlApplicationConfigurationArgs

data class ApplicationSqlApplicationConfigurationArgs(val inputs: Output<List<ApplicationInputArgs>>? = null) : ConvertibleToJava<ApplicationSqlApplicationConfigurationArgs>

Describes the inputs, outputs, and reference data sources for a SQL-based Kinesis Data Analytics application.

ApplicationSqlApplicationConfigurationArgsBuilder

class ApplicationSqlApplicationConfigurationArgsBuilder

Builder for ApplicationSqlApplicationConfigurationArgs.

ApplicationSystemRollbackConfigurationArgs

data class ApplicationSystemRollbackConfigurationArgs(val rollbackEnabled: Output<Boolean>) : ConvertibleToJava<ApplicationSystemRollbackConfigurationArgs>

Describes whether system initiated rollbacks are enabled for a Flink-based Kinesis Data Analytics application.

ApplicationSystemRollbackConfigurationArgsBuilder

class ApplicationSystemRollbackConfigurationArgsBuilder

Builder for ApplicationSystemRollbackConfigurationArgs.

ApplicationVpcConfigurationArgs

data class ApplicationVpcConfigurationArgs(val securityGroupIds: Output<List<String>>, val subnetIds: Output<List<String>>) : ConvertibleToJava<ApplicationVpcConfigurationArgs>

Describes the parameters of a VPC used by the application.

ApplicationVpcConfigurationArgsBuilder

class ApplicationVpcConfigurationArgsBuilder

Builder for ApplicationVpcConfigurationArgs.

ApplicationZeppelinApplicationConfigurationArgs

data class ApplicationZeppelinApplicationConfigurationArgs(val catalogConfiguration: Output<ApplicationCatalogConfigurationArgs>? = null, val customArtifactsConfiguration: Output<List<ApplicationCustomArtifactConfigurationArgs>>? = null, val deployAsApplicationConfiguration: Output<ApplicationDeployAsApplicationConfigurationArgs>? = null, val monitoringConfiguration: Output<ApplicationZeppelinMonitoringConfigurationArgs>? = null) : ConvertibleToJava<ApplicationZeppelinApplicationConfigurationArgs>

The configuration of a Kinesis Data Analytics Studio notebook.

ApplicationZeppelinApplicationConfigurationArgsBuilder

class ApplicationZeppelinApplicationConfigurationArgsBuilder

Builder for ApplicationZeppelinApplicationConfigurationArgs.

ApplicationZeppelinMonitoringConfigurationArgs

data class ApplicationZeppelinMonitoringConfigurationArgs(val logLevel: Output<ApplicationZeppelinMonitoringConfigurationLogLevel>? = null) : ConvertibleToJava<ApplicationZeppelinMonitoringConfigurationArgs>

Describes configuration parameters for Amazon CloudWatch logging for a Kinesis Data Analytics Studio notebook. For more information about CloudWatch logging, see Monitoring.

ApplicationZeppelinMonitoringConfigurationArgsBuilder

class ApplicationZeppelinMonitoringConfigurationArgsBuilder

Builder for ApplicationZeppelinMonitoringConfigurationArgs.

GetApplicationPlainArgs

data class GetApplicationPlainArgs(val applicationName: String) : ConvertibleToJava<GetApplicationPlainArgs>

GetApplicationPlainArgsBuilder

class GetApplicationPlainArgsBuilder

Builder for GetApplicationPlainArgs.