Package software.amazon.awssdk.services.kinesisanalytics.model

Interface InputDescription.Builder

All Superinterfaces:

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

Enclosing class:

InputDescription

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

Method Summary

Modifier and Type	Method	Description
InputDescription.Builder	inAppStreamNames(String... inAppStreamNames)	Returns the in-application stream names that are mapped to the stream source.
InputDescription.Builder	inAppStreamNames(Collection<String> inAppStreamNames)	Returns the in-application stream names that are mapped to the stream source.
InputDescription.Builder	inputId(String inputId)	Input ID associated with the application input.
default InputDescription.Builder	inputParallelism(Consumer<InputParallelism.Builder> inputParallelism)	Describes the configured parallelism (number of in-application streams mapped to the streaming source).
InputDescription.Builder	inputParallelism(InputParallelism inputParallelism)	Describes the configured parallelism (number of in-application streams mapped to the streaming source).
default InputDescription.Builder	inputProcessingConfigurationDescription(Consumer<InputProcessingConfigurationDescription.Builder> inputProcessingConfigurationDescription)	The description of the preprocessor that executes on records in this input before the application's code is run.
InputDescription.Builder	inputProcessingConfigurationDescription(InputProcessingConfigurationDescription inputProcessingConfigurationDescription)	The description of the preprocessor that executes on records in this input before the application's code is run.
default InputDescription.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.
InputDescription.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 InputDescription.Builder	inputStartingPositionConfiguration(Consumer<InputStartingPositionConfiguration.Builder> inputStartingPositionConfiguration)	Point at which the application is configured to read from the input stream.
InputDescription.Builder	inputStartingPositionConfiguration(InputStartingPositionConfiguration inputStartingPositionConfiguration)	Point at which the application is configured to read from the input stream.
default InputDescription.Builder	kinesisFirehoseInputDescription(Consumer<KinesisFirehoseInputDescription.Builder> kinesisFirehoseInputDescription)	If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
InputDescription.Builder	kinesisFirehoseInputDescription(KinesisFirehoseInputDescription kinesisFirehoseInputDescription)	If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
default InputDescription.Builder	kinesisStreamsInputDescription(Consumer<KinesisStreamsInputDescription.Builder> kinesisStreamsInputDescription)	If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
InputDescription.Builder	kinesisStreamsInputDescription(KinesisStreamsInputDescription kinesisStreamsInputDescription)	If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
InputDescription.Builder	namePrefix(String namePrefix)	In-application name prefix.

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

copy

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

applyMutation, build

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

equalsBySdkFields, sdkFields

Method Details

inputId

InputDescription.Builder inputId(String inputId)

Input ID associated with the application input. This is the ID that Amazon Kinesis Analytics assigns to each input configuration you add to your application.

Parameters:

inputId - Input ID associated with the application input. This is the ID that Amazon Kinesis Analytics assigns to each input configuration you add to your application.

Returns:

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

namePrefix

InputDescription.Builder namePrefix(String namePrefix)

In-application name prefix.

Parameters:

namePrefix - In-application name prefix.

Returns:

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

inAppStreamNames

InputDescription.Builder inAppStreamNames(Collection<String> inAppStreamNames)

Returns the in-application stream names that are mapped to the stream source.

Parameters:

inAppStreamNames - Returns the in-application stream names that are mapped to the stream source.

Returns:

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

inAppStreamNames

InputDescription.Builder inAppStreamNames(String... inAppStreamNames)

Returns the in-application stream names that are mapped to the stream source.

Parameters:

inAppStreamNames - Returns the in-application stream names that are mapped to the stream source.

Returns:

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

inputProcessingConfigurationDescription

InputDescription.Builder inputProcessingConfigurationDescription(InputProcessingConfigurationDescription inputProcessingConfigurationDescription)

The description of the preprocessor that executes on records in this input before the application's code is run.

Parameters:

inputProcessingConfigurationDescription - The description of the preprocessor that executes on records in this input before the application's code is run.

Returns:

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

inputProcessingConfigurationDescription

default InputDescription.Builder inputProcessingConfigurationDescription(Consumer<InputProcessingConfigurationDescription.Builder> inputProcessingConfigurationDescription)

The description of the preprocessor that executes on records in this input before the application's code is run.

This is a convenience method that creates an instance of the InputProcessingConfigurationDescription.Builder avoiding the need to create one manually via InputProcessingConfigurationDescription.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to inputProcessingConfigurationDescription(InputProcessingConfigurationDescription).

Parameters:

inputProcessingConfigurationDescription - a consumer that will call methods on InputProcessingConfigurationDescription.Builder

Returns:

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

See Also:

• inputProcessingConfigurationDescription(InputProcessingConfigurationDescription)

kinesisStreamsInputDescription

InputDescription.Builder kinesisStreamsInputDescription(KinesisStreamsInputDescription kinesisStreamsInputDescription)

If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.

Parameters:

kinesisStreamsInputDescription - If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.

Returns:

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

kinesisStreamsInputDescription

default InputDescription.Builder kinesisStreamsInputDescription(Consumer<KinesisStreamsInputDescription.Builder> kinesisStreamsInputDescription)

If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.

This is a convenience method that creates an instance of the KinesisStreamsInputDescription.Builder avoiding the need to create one manually via KinesisStreamsInputDescription.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to kinesisStreamsInputDescription(KinesisStreamsInputDescription).

Parameters:

kinesisStreamsInputDescription - a consumer that will call methods on KinesisStreamsInputDescription.Builder

Returns:

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

See Also:

• kinesisStreamsInputDescription(KinesisStreamsInputDescription)

kinesisFirehoseInputDescription

InputDescription.Builder kinesisFirehoseInputDescription(KinesisFirehoseInputDescription kinesisFirehoseInputDescription)

If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.

Parameters:

kinesisFirehoseInputDescription - If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.

Returns:

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

kinesisFirehoseInputDescription

default InputDescription.Builder kinesisFirehoseInputDescription(Consumer<KinesisFirehoseInputDescription.Builder> kinesisFirehoseInputDescription)

If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.

This is a convenience method that creates an instance of the KinesisFirehoseInputDescription.Builder avoiding the need to create one manually via KinesisFirehoseInputDescription.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to kinesisFirehoseInputDescription(KinesisFirehoseInputDescription).

Parameters:

kinesisFirehoseInputDescription - a consumer that will call methods on KinesisFirehoseInputDescription.Builder

Returns:

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

See Also:

• kinesisFirehoseInputDescription(KinesisFirehoseInputDescription)

inputSchema

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

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.

Returns:

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

inputSchema

default InputDescription.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.

This is a convenience method 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)

inputParallelism

InputDescription.Builder inputParallelism(InputParallelism inputParallelism)

Describes the configured parallelism (number of in-application streams mapped to the streaming source).

Parameters:

inputParallelism - Describes the configured parallelism (number of in-application streams mapped to the streaming source).

Returns:

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

inputParallelism

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

Describes the configured parallelism (number of in-application streams mapped to the streaming source).

This is a convenience method 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)

inputStartingPositionConfiguration

InputDescription.Builder inputStartingPositionConfiguration(InputStartingPositionConfiguration inputStartingPositionConfiguration)

Point at which the application is configured to read from the input stream.

Parameters:

inputStartingPositionConfiguration - Point at which the application is configured to read from the input stream.

Returns:

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

inputStartingPositionConfiguration

default InputDescription.Builder inputStartingPositionConfiguration(Consumer<InputStartingPositionConfiguration.Builder> inputStartingPositionConfiguration)

Point at which the application is configured to read from the input stream.

This is a convenience method that creates an instance of the InputStartingPositionConfiguration.Builder avoiding the need to create one manually via InputStartingPositionConfiguration.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to inputStartingPositionConfiguration(InputStartingPositionConfiguration).

Parameters:

inputStartingPositionConfiguration - a consumer that will call methods on InputStartingPositionConfiguration.Builder

Returns:

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

See Also:

• inputStartingPositionConfiguration(InputStartingPositionConfiguration)