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

Class IcebergMergeOptions

java.lang.Object

io.deephaven.enterprise.merge.impl.iceberg.IcebergMergeOptions

@Immutable(copy=false)
public abstract class IcebergMergeOptions
extends Object

Options for controlling how we merge a Deephaven table into an Iceberg table.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	IcebergMergeOptions.Builder

Constructor Summary

Constructors

Constructor	Description
IcebergMergeOptions()

Method Summary

Modifier and Type	Method	Description
abstract BaseMergeOptions	baseOptions()	Get the base options for this merge request.
static IcebergMergeOptions.Builder	builder()
abstract Optional<BuildCatalogOptions>	catalogOptions()	Get the catalog options to use when accessing Iceberg tables, instead of the one implied by the schema of the target table.
abstract List<String>	partitionValues()	The partition values to use when writing data.
abstract Optional<LoadTableOptions>	tableOptions()	Get the table options to use when accessing Iceberg tables, instead of the one implied by the schema of the target table.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

IcebergMergeOptions

public IcebergMergeOptions()

Method Details

builder

public static IcebergMergeOptions.Builder builder()

baseOptions

public abstract BaseMergeOptions baseOptions()

Get the base options for this merge request.

Returns:

the base options.

catalogOptions

public abstract Optional<BuildCatalogOptions> catalogOptions()

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

Returns:

the catalog options, or empty if the catalog options should be derived from the target table schema

tableOptions

public abstract Optional<LoadTableOptions> tableOptions()

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

Returns:

the table options, or empty if the table options should be derived from the target table schema

partitionValues

public abstract List<String> partitionValues()

The partition values to use when writing data.

Returns:

the partition values to use when writing data