Interface Input.Builder

All Superinterfaces:
Buildable, CopyableBuilder<Input.Builder,Input>, SdkBuilder<Input.Builder,Input>, SdkPojo
Enclosing class:
Input
public static interface Input.Builder extends SdkPojo, CopyableBuilder<Input.Builder,Input>

  • Method Details

    • namePrefix

      Input.Builder namePrefix(String 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 the InputParallelism 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 the InputProcessingConfiguration.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).

      Parameters:
      inputProcessingConfiguration - a consumer that will call methods on InputProcessingConfiguration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • kinesisStreamsInput

      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.

      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 or KinesisFirehoseInput 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 KinesisStreamsInput or KinesisFirehoseInput is required.

      This is a convenience method that creates an instance of the 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).

      Parameters:
      kinesisStreamsInput - a consumer that will call methods on KinesisStreamsInput.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • kinesisFirehoseInput

      Input.Builder 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.

      Note: Either KinesisStreamsInput or KinesisFirehoseInput 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 or KinesisFirehoseInput 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 KinesisStreamsInput or KinesisFirehoseInput is required.

      This is a convenience method that creates an instance of the 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).

      Parameters:
      kinesisFirehoseInput - a consumer that will call methods on KinesisFirehoseInput.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • inputParallelism

      Input.Builder inputParallelism(InputParallelism 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.

      Parameters:
      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.

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

    • inputParallelism

      default Input.Builder inputParallelism(Consumer<InputParallelism.Builder> 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 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:

    • inputSchema

      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.

      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

      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 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: