diff --git a/core/src/main/java/org/apache/iceberg/CatalogUtil.java b/core/src/main/java/org/apache/iceberg/CatalogUtil.java index 1ce3f73e8f98..9bca3966c07e 100644 --- a/core/src/main/java/org/apache/iceberg/CatalogUtil.java +++ b/core/src/main/java/org/apache/iceberg/CatalogUtil.java @@ -61,8 +61,11 @@ public class CatalogUtil { public static final String ICEBERG_CATALOG_TYPE_HADOOP = "hadoop"; public static final String ICEBERG_CATALOG_TYPE_HIVE = "hive"; - public static final String ICEBERG_CATALOG_HIVE = "org.apache.iceberg.hive.HiveCatalog"; + public static final String ICEBERG_CATALOG_TYPE_REST = "rest"; + public static final String ICEBERG_CATALOG_HADOOP = "org.apache.iceberg.hadoop.HadoopCatalog"; + public static final String ICEBERG_CATALOG_HIVE = "org.apache.iceberg.hive.HiveCatalog"; + public static final String ICEBERG_CATALOG_REST = "org.apache.iceberg.rest.RESTCatalog"; private CatalogUtil() {} @@ -238,6 +241,9 @@ public static Catalog buildIcebergCatalog(String name, Map optio case ICEBERG_CATALOG_TYPE_HADOOP: catalogImpl = ICEBERG_CATALOG_HADOOP; break; + case ICEBERG_CATALOG_TYPE_REST: + catalogImpl = ICEBERG_CATALOG_REST; + break; default: throw new UnsupportedOperationException("Unknown catalog type: " + catalogType); }