software.amazon.awssdk.services.kinesisanalyticsv2.model

Interface Input.Builder

All Superinterfaces:

Buildable, CopyableBuilder<Input.Builder,Input>, SdkBuilder<Input.Builder,Input>, SdkPojo

Enclosing class:

Input

public static interface Input.Builder
extends SdkPojo, CopyableBuilder<Input.Builder,Input>

Method Summary

Modifier and Type	Method and Description
default Input.Builder	inputParallelism(Consumer<InputParallelism.Builder> inputParallelism) Describes the number of in-application streams to create.
Input.Builder	inputParallelism(InputParallelism inputParallelism) Describes the number of in-application streams to create.
default Input.Builder	inputProcessingConfiguration(Consumer<InputProcessingConfiguration.Builder> inputProcessingConfiguration) The InputProcessingConfiguration for the input.
Input.Builder	inputProcessingConfiguration(InputProcessingConfiguration inputProcessingConfiguration) The InputProcessingConfiguration for the input.
default Input.Builder	inputSchema(Consumer<SourceSchema.Builder> inputSchema) 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.
Input.Builder	inputSchema(SourceSchema inputSchema) 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.
default Input.Builder	kinesisFirehoseInput(Consumer<KinesisFirehoseInput.Builder> kinesisFirehoseInput) If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
Input.Builder	kinesisFirehoseInput(KinesisFirehoseInput kinesisFirehoseInput) If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
default Input.Builder	kinesisStreamsInput(Consumer<KinesisStreamsInput.Builder> kinesisStreamsInput) If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
Input.Builder	kinesisStreamsInput(KinesisStreamsInput kinesisStreamsInput) If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
Input.Builder	namePrefix(String namePrefix) The name prefix to use when creating an in-application stream.

Methods inherited from interface software.amazon.awssdk.core.SdkPojo

sdkFields

Methods inherited from interface software.amazon.awssdk.utils.builder.CopyableBuilder

copy

Methods inherited from interface software.amazon.awssdk.utils.builder.SdkBuilder

applyMutation, build

Method Detail

namePrefix

Input.Builder namePrefix(String namePrefix)

The name prefix to use when creating an in-application stream. Suppose that you specify a prefix " MyInApplicationStream." Kinesis Data Analytics then creates one or more (as per the InputParallelism count you specified) in-application streams with the names " MyInApplicationStream_001," "MyInApplicationStream_002," and so on.

Parameters:

namePrefix - The name prefix to use when creating an in-application stream. Suppose that you specify a prefix " MyInApplicationStream." Kinesis Data Analytics then creates one or more (as per the InputParallelism count you specified) in-application streams with the names " MyInApplicationStream_001," "MyInApplicationStream_002," and so on.

Returns:

Returns a reference to this object so that method calls can be chained together.

inputProcessingConfiguration

Input.Builder inputProcessingConfiguration(InputProcessingConfiguration inputProcessingConfiguration)

The InputProcessingConfiguration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is InputLambdaProcessor.

Parameters:

inputProcessingConfiguration - The InputProcessingConfiguration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is InputLambdaProcessor.

Returns:

Returns a reference to this object so that method calls can be chained together.

inputProcessingConfiguration

default Input.Builder inputProcessingConfiguration(Consumer<InputProcessingConfiguration.Builder> inputProcessingConfiguration)

The InputProcessingConfiguration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is InputLambdaProcessor.

This is a convenience that creates an instance of the InputProcessingConfiguration.Builder avoiding the need to create one manually via InputProcessingConfiguration.builder(). When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to inputProcessingConfiguration(InputProcessingConfiguration).

Parameters:

inputProcessingConfiguration - a consumer that will call methods on InputProcessingConfiguration.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

inputProcessingConfiguration(InputProcessingConfiguration)

kinesisStreamsInput

Input.Builder kinesisStreamsInput(KinesisStreamsInput kinesisStreamsInput)

If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).

Parameters:

kinesisStreamsInput - If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).

Returns:

Returns a reference to this object so that method calls can be chained together.

kinesisStreamsInput

default Input.Builder kinesisStreamsInput(Consumer<KinesisStreamsInput.Builder> kinesisStreamsInput)

If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).

This is a convenience that creates an instance of the KinesisStreamsInput.Builder avoiding the need to create one manually via KinesisStreamsInput.builder(). When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to kinesisStreamsInput(KinesisStreamsInput).

Parameters:

kinesisStreamsInput - a consumer that will call methods on KinesisStreamsInput.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

kinesisStreamsInput(KinesisStreamsInput)

kinesisFirehoseInput

Input.Builder kinesisFirehoseInput(KinesisFirehoseInput kinesisFirehoseInput)

If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.

Parameters:

kinesisFirehoseInput - If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.

Returns:

Returns a reference to this object so that method calls can be chained together.

kinesisFirehoseInput

default Input.Builder kinesisFirehoseInput(Consumer<KinesisFirehoseInput.Builder> kinesisFirehoseInput)

If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.

This is a convenience that creates an instance of the KinesisFirehoseInput.Builder avoiding the need to create one manually via KinesisFirehoseInput.builder(). When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to kinesisFirehoseInput(KinesisFirehoseInput).

Parameters:

kinesisFirehoseInput - a consumer that will call methods on KinesisFirehoseInput.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

kinesisFirehoseInput(KinesisFirehoseInput)

inputParallelism

Input.Builder inputParallelism(InputParallelism inputParallelism)

Describes the number of in-application streams to create.

Parameters:

inputParallelism - Describes the number of in-application streams to create.

Returns:

Returns a reference to this object so that method calls can be chained together.

inputParallelism

default Input.Builder inputParallelism(Consumer<InputParallelism.Builder> inputParallelism)

Describes the number of in-application streams to create.

This is a convenience that creates an instance of the InputParallelism.Builder avoiding the need to create one manually via InputParallelism.builder(). When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to inputParallelism(InputParallelism).

Parameters:

inputParallelism - a consumer that will call methods on InputParallelism.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

inputParallelism(InputParallelism)

inputSchema

Input.Builder inputSchema(SourceSchema inputSchema)

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.

Also used to describe the format of the reference data source.

Parameters:

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

Also used to describe the format of the reference data source.

Returns:

Returns a reference to this object so that method calls can be chained together.

inputSchema

default Input.Builder inputSchema(Consumer<SourceSchema.Builder> inputSchema)

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.

Also used to describe the format of the reference data source.

This is a convenience that creates an instance of the SourceSchema.Builder avoiding the need to create one manually via SourceSchema.builder(). When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to inputSchema(SourceSchema).

Parameters:

inputSchema - a consumer that will call methods on SourceSchema.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

inputSchema(SourceSchema)