CatalogLoader

All Superinterfaces:: Cloneable, Serializable

All Known Implementing Classes:: CatalogLoader.CustomCatalogLoader, CatalogLoader.HadoopCatalogLoader, CatalogLoader.HiveCatalogLoader, CatalogLoader.RESTCatalogLoader

public interface CatalogLoader extends Serializable, Cloneable

Serializable loader to load an Iceberg Catalog.

Nested Class Summary

Nested Classes

Modifier and Type

Interface

Description

static class

CatalogLoader.CustomCatalogLoader

static class

CatalogLoader.HadoopCatalogLoader

static class

CatalogLoader.HiveCatalogLoader

static class

CatalogLoader.RESTCatalogLoader
Method Summary

Modifier and Type

Method

Description

CatalogLoader

clone()

Clone a CatalogLoader.

static CatalogLoader

custom(String name, Map<String,String> properties, org.apache.hadoop.conf.Configuration hadoopConf, String impl)

static CatalogLoader

hadoop(String name, org.apache.hadoop.conf.Configuration hadoopConf, Map<String,String> properties)

static CatalogLoader

hive(String name, org.apache.hadoop.conf.Configuration hadoopConf, Map<String,String> properties)

Catalog

loadCatalog()

Create a new catalog with the provided properties.

static CatalogLoader

rest(String name, org.apache.hadoop.conf.Configuration hadoopConf, Map<String,String> properties)

Method Details
- 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
- clone
  
  CatalogLoader clone()
  
  Clone a CatalogLoader.
- hadoop
  
  static CatalogLoader hadoop(String name, org.apache.hadoop.conf.Configuration hadoopConf, Map<String,String> properties)
- hive
  
  static CatalogLoader hive(String name, org.apache.hadoop.conf.Configuration hadoopConf, Map<String,String> properties)
- rest
  
  static CatalogLoader rest(String name, org.apache.hadoop.conf.Configuration hadoopConf, Map<String,String> properties)
- custom
  
  static CatalogLoader custom(String name, Map<String,String> properties, org.apache.hadoop.conf.Configuration hadoopConf, String impl)