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)	The input ID that is 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)	The point at which the application is configured to read from the input stream.
InputDescription.Builder	inputStartingPositionConfiguration(InputStartingPositionConfiguration inputStartingPositionConfiguration)	The point at which the application is configured to read from the input stream.
default InputDescription.Builder	kinesisFirehoseInputDescription(Consumer<KinesisFirehoseInputDescription.Builder> kinesisFirehoseInputDescription)	If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.
InputDescription.Builder	kinesisFirehoseInputDescription(KinesisFirehoseInputDescription kinesisFirehoseInputDescription)	If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.
default InputDescription.Builder	kinesisStreamsInputDescription(Consumer<KinesisStreamsInputDescription.Builder> kinesisStreamsInputDescription)	If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).
InputDescription.Builder	kinesisStreamsInputDescription(KinesisStreamsInputDescription kinesisStreamsInputDescription)	If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).
InputDescription.Builder	namePrefix(String namePrefix)	The 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)

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

Parameters:

inputId - The input ID that is associated with the application input. This is the ID that Kinesis Data Analytics assigns to each input configuration that 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)

The in-application name prefix.

Parameters:

namePrefix - The 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 a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).

Parameters:

kinesisStreamsInputDescription - If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).

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 a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).

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 a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.

Parameters:

kinesisFirehoseInputDescription - If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.

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 a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.

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)

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

Parameters:

inputStartingPositionConfiguration - The 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)

The 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)