Interface Input.Builder
- All Superinterfaces:
Buildable
,CopyableBuilder<Input.Builder,
,Input> SdkBuilder<Input.Builder,
,Input> SdkPojo
- Enclosing class:
Input
-
Method Summary
Modifier and TypeMethodDescriptiondefault Input.Builder
inputParallelism
(Consumer<InputParallelism.Builder> inputParallelism) Describes the number of in-application streams to create.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.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.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.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).kinesisStreamsInput
(KinesisStreamsInput kinesisStreamsInput) If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).namePrefix
(String namePrefix) The name prefix to use when creating an in-application stream.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
-
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 theInputParallelism
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 theInputParallelism
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 method that creates an instance of theInputProcessingConfiguration.Builder
avoiding the need to create one manually viaInputProcessingConfiguration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toinputProcessingConfiguration(InputProcessingConfiguration)
.- Parameters:
inputProcessingConfiguration
- a consumer that will call methods onInputProcessingConfiguration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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 method that creates an instance of theKinesisStreamsInput.Builder
avoiding the need to create one manually viaKinesisStreamsInput.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed tokinesisStreamsInput(KinesisStreamsInput)
.- Parameters:
kinesisStreamsInput
- a consumer that will call methods onKinesisStreamsInput.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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 method that creates an instance of theKinesisFirehoseInput.Builder
avoiding the need to create one manually viaKinesisFirehoseInput.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed tokinesisFirehoseInput(KinesisFirehoseInput)
.- Parameters:
kinesisFirehoseInput
- a consumer that will call methods onKinesisFirehoseInput.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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
Describes the number of in-application streams to create.
This is a convenience method that creates an instance of theInputParallelism.Builder
avoiding the need to create one manually viaInputParallelism.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toinputParallelism(InputParallelism)
.- Parameters:
inputParallelism
- a consumer that will call methods onInputParallelism.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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
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 method that creates an instance of theSourceSchema.Builder
avoiding the need to create one manually viaSourceSchema.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toinputSchema(SourceSchema)
.- Parameters:
inputSchema
- a consumer that will call methods onSourceSchema.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-