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 Firehose delivery stream, identifies the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.kinesisFirehoseInput
(KinesisFirehoseInput kinesisFirehoseInput) If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.default Input.Builder
kinesisStreamsInput
(Consumer<KinesisStreamsInput.Builder> kinesisStreamsInput) If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.kinesisStreamsInput
(KinesisStreamsInput kinesisStreamsInput) If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.namePrefix
(String namePrefix) 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
Name prefix to use when creating an in-application stream. Suppose that you specify a prefix "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per the
InputParallelism
count you specified) in-application streams with names "MyInApplicationStream_001," "MyInApplicationStream_002," and so on.- Parameters:
namePrefix
- Name prefix to use when creating an in-application stream. Suppose that you specify a prefix "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per theInputParallelism
count you specified) in-application streams with 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 stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
Note: Either
KinesisStreamsInput
orKinesisFirehoseInput
is required.- Parameters:
kinesisStreamsInput
- If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.Note: Either
KinesisStreamsInput
orKinesisFirehoseInput
is required.- 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 stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
Note: Either
This is a convenience method that creates an instance of theKinesisStreamsInput
orKinesisFirehoseInput
is required.KinesisStreamsInput.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 Firehose delivery stream, identifies the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
Note: Either
KinesisStreamsInput
orKinesisFirehoseInput
is required.- Parameters:
kinesisFirehoseInput
- If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.Note: Either
KinesisStreamsInput
orKinesisFirehoseInput
is required.- 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 Firehose delivery stream, identifies the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
Note: Either
This is a convenience method that creates an instance of theKinesisStreamsInput
orKinesisFirehoseInput
is required.KinesisFirehoseInput.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.
Data from your source is routed to these in-application input streams.
- Parameters:
inputParallelism
- Describes the number of in-application streams to create.Data from your source is routed to these in-application input streams.
- 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.
Data from your source is routed to these in-application input streams.
(see Configuring Application Input.
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:
-