Package io.deephaven.iceberg.util

Class IcebergTableWriter

java.lang.Object
io.deephaven.iceberg.util.IcebergTableWriter
public class IcebergTableWriter extends Object
This class is responsible for writing Deephaven tables to an Iceberg table. Each instance of this class is associated with a single IcebergTableAdapter and can be used to write multiple Deephaven tables to this Iceberg table.

  • Method Details

    • append

      public void append(@NotNull @NotNull IcebergWriteInstructions writeInstructions)
      Append the provided Deephaven IcebergWriteInstructions.tables() as new partitions to the existing Iceberg table in a single snapshot. This method will not perform any compatibility checks between the existing schema and the provided Deephaven tables.
      Parameters:
      writeInstructions - The instructions for customizations while writing.

    • writeDataFiles

      public List<org.apache.iceberg.DataFile> writeDataFiles(@NotNull @NotNull IcebergWriteInstructions writeInstructions)
      Writes data from Deephaven IcebergWriteInstructions.tables() to an Iceberg table without creating a new snapshot. This method returns a list of data files that were written. Users can use this list to create a transaction/snapshot if needed. This method will not perform any compatibility checks between the existing schema and the provided Deephaven tables.
      Parameters:
      writeInstructions - The instructions for customizations while writing.