IcebergUtils (combined-javadoc 0.39.4 API)

java.lang.Object

io.deephaven.iceberg.base.IcebergUtils

public final class IcebergUtils extends Object

Constructor Summary

Constructors

Constructor

Description

IcebergUtils()
Method Summary

Modifier and Type

Method

Description

static boolean

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

static URI

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

static boolean

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

static URI

locationUri(@NotNull org.apache.iceberg.Table table)

static String

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

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.

static void

verifyRequiredFields(org.apache.iceberg.Schema tableSchema, TableDefinition tableDefinition)

Check that all required fields are present in the table definition

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)
- 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.