Package io.deephaven.iceberg.util

Class TableWriterOptions

java.lang.Object
io.deephaven.iceberg.util.TableWriterOptions
Direct Known Subclasses:
TableParquetWriterOptions
public abstract class TableWriterOptions extends Object

  • Constructor Details

    • TableWriterOptions

      public TableWriterOptions()

  • Method Details

    • tableDefinition

      public abstract TableDefinition tableDefinition()
      The TableDefinition to use when writing Iceberg data files, instead of the one implied by the table being written itself. This definition can be used to skip some columns or add additional columns with null values.

    • dataInstructions

      public abstract Optional<Object> dataInstructions()
      The data instructions to use for reading/writing the Iceberg data files (might be S3Instructions or other cloud provider-specific instructions).

    • schemaProvider

      @Default public SchemaProvider schemaProvider()
      Used to extract a Schema from a table. That schema will be used in conjunction with the fieldIdToColumnName() to map Deephaven columns from tableDefinition() to Iceberg columns. If fieldIdToColumnName() is not provided, the mapping is done by column name.

      Users can specify how to extract the schema in multiple ways (by schema ID, snapshot ID, etc.).

      Defaults to SchemaProvider.fromCurrent(), which means use the current schema from the table.

    • fieldIdToColumnName

      public abstract Map<Integer,String> fieldIdToColumnName()
      A one-to-one map from Iceberg field IDs from the schemaProvider() to Deephaven column names from the tableDefinition().