Interface ReferenceDataSource.Builder

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

  • Method Details

    • tableName

      ReferenceDataSource.Builder tableName(String tableName)

      Name of the in-application table to create.

      Parameters:
      tableName - Name of the in-application table to create.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • s3ReferenceDataSource

      ReferenceDataSource.Builder s3ReferenceDataSource(S3ReferenceDataSource s3ReferenceDataSource)

      Identifies the S3 bucket and object that contains the reference data. Also identifies the IAM role Amazon Kinesis Analytics can assume to read this object on your behalf. An Amazon Kinesis Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.

      Parameters:
      s3ReferenceDataSource - Identifies the S3 bucket and object that contains the reference data. Also identifies the IAM role Amazon Kinesis Analytics can assume to read this object on your behalf. An Amazon Kinesis Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • s3ReferenceDataSource

      default ReferenceDataSource.Builder s3ReferenceDataSource(Consumer<S3ReferenceDataSource.Builder> s3ReferenceDataSource)

      Identifies the S3 bucket and object that contains the reference data. Also identifies the IAM role Amazon Kinesis Analytics can assume to read this object on your behalf. An Amazon Kinesis Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.

      This is a convenience method that creates an instance of the S3ReferenceDataSource.Builder avoiding the need to create one manually via S3ReferenceDataSource.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to s3ReferenceDataSource(S3ReferenceDataSource).

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

    • referenceSchema

      ReferenceDataSource.Builder referenceSchema(SourceSchema referenceSchema)

      Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

      Parameters:
      referenceSchema - Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • referenceSchema

      default ReferenceDataSource.Builder referenceSchema(Consumer<SourceSchema.Builder> referenceSchema)

      Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

      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 referenceSchema(SourceSchema).

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