Package io.deephaven.enterprise.iceberg

Class IcebergConfiguration

java.lang.Object
io.deephaven.enterprise.iceberg.IcebergConfiguration
public final class IcebergConfiguration extends Object
Contains the configuration parameters needed to connect to an Iceberg Catalog and fetch Iceberg Tables.

  • Method Details

    • getCatalogType

      @NotNull public @NotNull String getCatalogType()
      Get the catalog type. See CatalogUtil for possible values
      Returns:
      the catalog type

    • getCatalogUri

      @NotNull public @NotNull String getCatalogUri()
      Get the URI of the catalog.
      Returns:
      the catalog uri

    • getCatalogName

      @Nullable public @Nullable String getCatalogName()
      Get the optional catalog name. May be null.
      Returns:
      the catalog name

    • getProperties

      @NotNull public @NotNull Map<String,String> getProperties()
      Get the plaintext properties for Iceberg.
      Returns:
      the properties for iceberg

    • getSecrets

      @NotNull public @NotNull Map<String,String> getSecrets()
      Get the map of protected secrets for Iceberg. The keys are property names, for example "s3.secret-access-key", while the values are secret names that will be retrieved when needed from the SecretsService.
      Returns:
      the map of secrets

    • getHadoopConfig

      @NotNull public @NotNull Map<String,String> getHadoopConfig()
      Get the map of values for the hadoop configuration, required for Catalog access. See Hadoop Configuration
      Returns:
      the hadoop configuration map.

    • getWarehouseUri

      @NotNull public @NotNull String getWarehouseUri()
      Get the warehouse URI, that is, where the data actually resides.
      Returns:
      the warehouse URI

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object