Package io.deephaven.enterprise.merge.impl.iceberg

Interface IcebergMergeOptions.Builder

Enclosing class:

IcebergMergeOptions

public static interface IcebergMergeOptions.Builder

Method Summary

Modifier and Type	Method	Description
IcebergMergeOptions.Builder	addAllPartitionValues(@NotNull Iterable<String> partitionValues)	Set the partition values to use when writing data.
IcebergMergeOptions.Builder	addPartitionValues(@NotNull String... partitionValues)	Set the partition values to use when writing data.
IcebergMergeOptions.Builder	baseOptions(@NotNull BaseMergeOptions baseOptions)	Set the base options for this merge request.
IcebergMergeOptions	build()	Generates the IcebergMergeOptions based on the inputs to this IcebergMergeOptions.Builder instance.
IcebergMergeOptions.Builder	catalogOptions(@NotNull BuildCatalogOptions catalogOptions)	Set the catalog options to use when accessing Iceberg tables, instead of the one implied by the schema of the target table.
IcebergMergeOptions.Builder	tableOptions(@NotNull LoadTableOptions tableOptions)	Set the table options to use when accessing Iceberg tables, instead of the one implied by the schema of the target table.

Method Details

baseOptions

@ScriptApi
IcebergMergeOptions.Builder baseOptions(@NotNull
 @NotNull BaseMergeOptions baseOptions)

Set the base options for this merge request.

Parameters:

baseOptions - the base options for this merge request.

Returns:

this IcebergMergeOptions.Builder

catalogOptions

@ScriptApi
IcebergMergeOptions.Builder catalogOptions(@NotNull
 @NotNull BuildCatalogOptions catalogOptions)

Set the catalog options to use when accessing Iceberg tables, instead of the one implied by the schema of the target table.

Parameters:

catalogOptions - the catalog options

Returns:

this IcebergMergeOptions.Builder

tableOptions

@ScriptApi
IcebergMergeOptions.Builder tableOptions(@NotNull
 @NotNull LoadTableOptions tableOptions)

Set the table options to use when accessing Iceberg tables, instead of the one implied by the schema of the target table.

Parameters:

tableOptions - the table options

Returns:

this IcebergMergeOptions.Builder

addAllPartitionValues

@ScriptApi
IcebergMergeOptions.Builder addAllPartitionValues(@NotNull
 @NotNull Iterable<String> partitionValues)

Set the partition values to use when writing data.

For example, if the table is partitioned by (Date, Region), and the date for the new partition is "2024-01-01" and the region is "US", then the partition values would be "Date=2024-01-01" and "Region=US".

Note: The following API may change in the future (DH-20330).

Parameters:

partitionValues - the partition values to use when writing data

Returns:

this IcebergMergeOptions.Builder

addPartitionValues

@ScriptApi
IcebergMergeOptions.Builder addPartitionValues(@NotNull
 @NotNull String... partitionValues)

Set the partition values to use when writing data.

For example, if the table is partitioned by (Date, Region), and the date for the new partition is "2024-01-01" and the region is "US", then the partition values would be "Date=2024-01-01" and "Region=US".

Note: The following API may change in the future (DH-20330).

Parameters:

partitionValues - the partition values to use when writing data

Returns:

this IcebergMergeOptions.Builder

build

IcebergMergeOptions build()

Generates the IcebergMergeOptions based on the inputs to this IcebergMergeOptions.Builder instance.

Returns:

an immutable instance of IcebergMergeOptions