Package io.deephaven.iceberg.base

Class IcebergUtils

java.lang.Object
io.deephaven.iceberg.base.IcebergUtils
public final class IcebergUtils extends Object

  • Constructor Details

    • IcebergUtils

      public IcebergUtils()

  • Method Details

    • maybeResolveRelativePath

      public static String maybeResolveRelativePath(@NotNull @NotNull String path, @NotNull @NotNull org.apache.iceberg.io.FileIO io)

    • locationUri

      public static URI locationUri(@NotNull @NotNull org.apache.iceberg.Table table)

    • dataFileUri

      public static URI dataFileUri(@NotNull @NotNull org.apache.iceberg.Table table, @NotNull @NotNull org.apache.iceberg.DataFile dataFile)

    • convertToDHType

      @Deprecated(forRemoval=true) public static Type<?> convertToDHType(@NotNull @NotNull org.apache.iceberg.types.Type icebergType)
      Deprecated, for removal: This API element is subject to removal in a future version.
      prefer TypeInference.of(Type)
      Convert an Iceberg data type to a Deephaven type.
      Parameters:
      icebergType - The Iceberg data type to be converted.
      Returns:
      The converted Deephaven type.

    • convertToIcebergType

      @Deprecated(forRemoval=true) public static org.apache.iceberg.types.Type convertToIcebergType(Class<?> columnType)
      Deprecated, for removal: This API element is subject to removal in a future version.
      prefer TypeInference.of(io.deephaven.qst.type.Type, TypeUtil.NextID)
      Convert a Deephaven type to an Iceberg type.
      Parameters:
      columnType - The Deephaven type to be converted.
      Returns:
      The converted Iceberg type.

    • createNamespaceIfNotExists

      public static boolean createNamespaceIfNotExists(@NotNull @NotNull org.apache.iceberg.catalog.Catalog catalog, @NotNull @NotNull org.apache.iceberg.catalog.Namespace namespace)

    • dropNamespaceIfExists

      public static boolean dropNamespaceIfExists(@NotNull @NotNull org.apache.iceberg.catalog.Catalog catalog, @NotNull @NotNull org.apache.iceberg.catalog.Namespace namespace)

    • verifyRequiredFields

      public static void verifyRequiredFields(org.apache.iceberg.Schema tableSchema, TableDefinition tableDefinition)
      Check that all required fields are present in the table definition

    • verifyPartitioningColumns

      public static void verifyPartitioningColumns(org.apache.iceberg.PartitionSpec tablePartitionSpec, TableDefinition tableDefinition)
      Check that all the partitioning columns from the partition spec are of supported types and are present in the Table Definition.