Package io.deephaven.iceberg.util

Class IcebergReadInstructions

java.lang.Object
io.deephaven.iceberg.util.IcebergReadInstructions
@Immutable public abstract class IcebergReadInstructions extends Object
This class provides instructions intended for reading Iceberg catalogs and tables. The default values documented in this class may change in the future. As such, callers may wish to explicitly set the values.

  • Field Details

  • Constructor Details

    • IcebergReadInstructions

      public IcebergReadInstructions()

  • Method Details

    • builder

      public static IcebergReadInstructions.Builder builder()

    • tableDefinition

      public abstract Optional<TableDefinition> tableDefinition()
      The TableDefinition to use when reading Iceberg data files.

    • dataInstructions

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

    • columnRenames

      public abstract Map<String,String> columnRenames()
      A map of rename instructions from Iceberg to Deephaven column names to use when reading the Iceberg data files.

    • withColumnRenames

      public abstract IcebergReadInstructions withColumnRenames(Map<String,? extends String> entries)
      Return a copy of this instructions object with the column renames replaced by entries.

    • updateMode

      @Default public IcebergUpdateMode updateMode()
      The IcebergUpdateMode mode to use when reading the Iceberg data files. Default is IcebergUpdateMode.staticMode().

    • snapshotId

      public abstract OptionalLong snapshotId()
      The identifier of the snapshot to load for reading. If both this and snapshot() are provided, the Snapshot.snapshotId() should match this. Otherwise, only one of them should be provided. If neither is provided, the latest snapshot will be loaded.

    • withSnapshotId

      public abstract IcebergReadInstructions withSnapshotId(long value)
      Return a copy of this instructions object with the snapshot ID replaced by value.

    • snapshot

      public abstract Optional<org.apache.iceberg.Snapshot> snapshot()
      The snapshot to load for reading. If both this and snapshotId() are provided, the Snapshot.snapshotId() should match the snapshotId(). Otherwise, only one of them should be provided. If neither is provided, the latest snapshot will be loaded.

    • withSnapshot

      public abstract IcebergReadInstructions withSnapshot(org.apache.iceberg.Snapshot value)
      Return a copy of this instructions object with the snapshot replaced by value.