Interface S3IcebergCatalogTarget.Builder

All Superinterfaces:
Buildable, CopyableBuilder<S3IcebergCatalogTarget.Builder,S3IcebergCatalogTarget>, SdkBuilder<S3IcebergCatalogTarget.Builder,S3IcebergCatalogTarget>, SdkPojo
Enclosing class:
S3IcebergCatalogTarget
@Mutable @NotThreadSafe public static interface S3IcebergCatalogTarget.Builder extends SdkPojo, CopyableBuilder<S3IcebergCatalogTarget.Builder,S3IcebergCatalogTarget>

  • Method Details

    • name

      S3IcebergCatalogTarget.Builder name(String name)

      The name of the Iceberg catalog target.

      Parameters:
      name - The name of the Iceberg catalog target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • inputs

      S3IcebergCatalogTarget.Builder inputs(Collection<String> inputs)

      The input connection for the Iceberg catalog target.

      Parameters:
      inputs - The input connection for the Iceberg catalog target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • inputs

      S3IcebergCatalogTarget.Builder inputs(String... inputs)

      The input connection for the Iceberg catalog target.

      Parameters:
      inputs - The input connection for the Iceberg catalog target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • partitionKeys

      S3IcebergCatalogTarget.Builder partitionKeys(Collection<? extends Collection<String>> partitionKeys)

      A list of partition keys for the Iceberg table.

      Parameters:
      partitionKeys - A list of partition keys for the Iceberg table.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • partitionKeys

      S3IcebergCatalogTarget.Builder partitionKeys(Collection<String>... partitionKeys)

      A list of partition keys for the Iceberg table.

      Parameters:
      partitionKeys - A list of partition keys for the Iceberg table.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • table

      S3IcebergCatalogTarget.Builder table(String table)

      The name of the table to write to in the catalog.

      Parameters:
      table - The name of the table to write to in the catalog.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • database

      S3IcebergCatalogTarget.Builder database(String database)

      The name of the database to write to.

      Parameters:
      database - The name of the database to write to.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • additionalOptions

      S3IcebergCatalogTarget.Builder additionalOptions(Map<String,String> additionalOptions)

      Specifies additional connection options for the Iceberg catalog target.

      Parameters:
      additionalOptions - Specifies additional connection options for the Iceberg catalog target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • schemaChangePolicy

      S3IcebergCatalogTarget.Builder schemaChangePolicy(CatalogSchemaChangePolicy schemaChangePolicy)

      The policy for handling schema changes in the catalog target.

      Parameters:
      schemaChangePolicy - The policy for handling schema changes in the catalog target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • schemaChangePolicy

      default S3IcebergCatalogTarget.Builder schemaChangePolicy(Consumer<CatalogSchemaChangePolicy.Builder> schemaChangePolicy)

      The policy for handling schema changes in the catalog target.

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

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

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

    • autoDataQuality

      S3IcebergCatalogTarget.Builder autoDataQuality(AutoDataQuality autoDataQuality)

      Specifies whether to automatically enable data quality evaluation for the S3 Iceberg catalog target. When set to true, data quality checks are performed automatically during the write operation.

      Parameters:
      autoDataQuality - Specifies whether to automatically enable data quality evaluation for the S3 Iceberg catalog target. When set to true, data quality checks are performed automatically during the write operation.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • autoDataQuality

      default S3IcebergCatalogTarget.Builder autoDataQuality(Consumer<AutoDataQuality.Builder> autoDataQuality)

      Specifies whether to automatically enable data quality evaluation for the S3 Iceberg catalog target. When set to true, data quality checks are performed automatically during the write operation.

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

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

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