public static interface Input.Builder extends CopyableBuilder<Input.Builder,Input>
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 Firehose delivery stream, identifies the Firehose delivery
stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
|
Input.Builder |
kinesisFirehoseInput(KinesisFirehoseInput kinesisFirehoseInput)
If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the Firehose 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.
|
Input.Builder |
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.
|
Input.Builder |
namePrefix(String namePrefix)
Name prefix to use when creating in-application stream.
|
copy
applyMutation, build
Input.Builder namePrefix(String namePrefix)
Name prefix to use when creating in-application stream. Suppose you specify a prefix "MyInApplicationStream".
Amazon Kinesis Analytics will then create one or more (as per the InputParallelism
count you
specified) in-application streams with names "MyInApplicationStream_001", "MyInApplicationStream_002" and so
on.
namePrefix
- Name prefix to use when creating in-application stream. Suppose you specify a prefix
"MyInApplicationStream". Amazon Kinesis Analytics will then create one or more (as per the
InputParallelism
count you specified) in-application streams with names
"MyInApplicationStream_001", "MyInApplicationStream_002" and so on.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.
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.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 theInputProcessingConfiguration.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)
.inputProcessingConfiguration
- a consumer that will call methods on InputProcessingConfiguration.Builder
inputProcessingConfiguration(InputProcessingConfiguration)
Input.Builder 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.
Note: Either KinesisStreamsInput
or KinesisFirehoseInput
is required.
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
or KinesisFirehoseInput
is required.
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 KinesisStreamsInput
or KinesisFirehoseInput
is required.
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)
.kinesisStreamsInput
- a consumer that will call methods on KinesisStreamsInput.Builder
kinesisStreamsInput(KinesisStreamsInput)
Input.Builder kinesisFirehoseInput(KinesisFirehoseInput kinesisFirehoseInput)
If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the Firehose delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
Note: Either KinesisStreamsInput
or KinesisFirehoseInput
is required.
kinesisFirehoseInput
- If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the Firehose
delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on
your behalf.
Note: Either KinesisStreamsInput
or KinesisFirehoseInput
is required.
default Input.Builder kinesisFirehoseInput(Consumer<KinesisFirehoseInput.Builder> kinesisFirehoseInput)
If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the Firehose delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
Note: Either KinesisStreamsInput
or KinesisFirehoseInput
is required.
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)
.kinesisFirehoseInput
- a consumer that will call methods on KinesisFirehoseInput.Builder
kinesisFirehoseInput(KinesisFirehoseInput)
Input.Builder inputParallelism(InputParallelism inputParallelism)
Describes the number of in-application streams to create.
Data from your source will be routed to these in-application input streams.
inputParallelism
- Describes the number of in-application streams to create.
Data from your source will be routed to these in-application input streams.
default Input.Builder inputParallelism(Consumer<InputParallelism.Builder> inputParallelism)
Describes the number of in-application streams to create.
Data from your source will be routed to these in-application input streams.
(see Configuring Application Input.
This is a convenience that creates an instance of theInputParallelism.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)
.inputParallelism
- a consumer that will call methods on InputParallelism.Builder
inputParallelism(InputParallelism)
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.
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.
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 theSourceSchema.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)
.inputSchema
- a consumer that will call methods on SourceSchema.Builder
inputSchema(SourceSchema)
Copyright © 2017 Amazon Web Services, Inc. All Rights Reserved.