org.apache.iceberg.flink

Interface CatalogLoader

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

CatalogLoader.HadoopCatalogLoader, CatalogLoader.HiveCatalogLoader

public interface CatalogLoader
extends java.io.Serializable

Serializable loader to load an Iceberg Catalog.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	CatalogLoader.HadoopCatalogLoader
static class	CatalogLoader.HiveCatalogLoader

Method Summary

Modifier and Type	Method and Description
static CatalogLoader	hadoop(java.lang.String name, org.apache.hadoop.conf.Configuration hadoopConf, java.lang.String warehouseLocation)
static CatalogLoader	hive(java.lang.String name, org.apache.hadoop.conf.Configuration hadoopConf, java.lang.String uri, java.lang.String warehouse, int clientPoolSize)
Catalog	loadCatalog() Create a new catalog with the provided properties.

Method Detail

loadCatalog

Catalog loadCatalog()

Create a new catalog with the provided properties. NOTICE: for flink, we may initialize the CatalogLoader at flink sql client side or job manager side, and then serialize this catalog loader to task manager, finally deserialize it and create a new catalog at task manager side.

Returns:

a newly created Catalog

hadoop

static CatalogLoader hadoop(java.lang.String name,
                            org.apache.hadoop.conf.Configuration hadoopConf,
                            java.lang.String warehouseLocation)

hive

static CatalogLoader hive(java.lang.String name,
                          org.apache.hadoop.conf.Configuration hadoopConf,
                          java.lang.String uri,
                          java.lang.String warehouse,
                          int clientPoolSize)