kinesisanalyticsv2/aws.sdk.kotlin.services.kinesisanalyticsv2.model/InputUpdate/Builder

Builder

Properties

The input ID of the application input to be updated.

var inputParallelismUpdate: InputParallelismUpdate?

Describes the parallelism updates (the number of in-application streams Kinesis Data Analytics creates for the specific streaming source).

inputProcessingConfigurationUpdate

var inputProcessingConfigurationUpdate: InputProcessingConfigurationUpdate?

Describes updates to an InputProcessingConfiguration.

inputSchemaUpdate

var inputSchemaUpdate: InputSchemaUpdate?

Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.

kinesisFirehoseInputUpdate

var kinesisFirehoseInputUpdate: KinesisFirehoseInputUpdate?

If a Kinesis Data Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN.

kinesisStreamsInputUpdate

var kinesisStreamsInputUpdate: KinesisStreamsInputUpdate?

If a Kinesis data stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN).

namePrefixUpdate

var namePrefixUpdate: String?

The name prefix for in-application streams that Kinesis Data Analytics creates for the specific streaming source.

Functions

inputParallelismUpdate

fun inputParallelismUpdate(block: InputParallelismUpdate.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.kinesisanalyticsv2.model.InputParallelismUpdate inside the given block

inputProcessingConfigurationUpdate

fun inputProcessingConfigurationUpdate(block: InputProcessingConfigurationUpdate.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.kinesisanalyticsv2.model.InputProcessingConfigurationUpdate inside the given block

inputSchemaUpdate

fun inputSchemaUpdate(block: InputSchemaUpdate.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.kinesisanalyticsv2.model.InputSchemaUpdate inside the given block

kinesisFirehoseInputUpdate

fun kinesisFirehoseInputUpdate(block: KinesisFirehoseInputUpdate.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.kinesisanalyticsv2.model.KinesisFirehoseInputUpdate inside the given block

kinesisStreamsInputUpdate

fun kinesisStreamsInputUpdate(block: KinesisStreamsInputUpdate.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.kinesisanalyticsv2.model.KinesisStreamsInputUpdate inside the given block