Package org.apache.iceberg.flink

Interface CatalogLoader

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

CatalogLoader.CustomCatalogLoader, 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	Description
static class	CatalogLoader.CustomCatalogLoader
static class	CatalogLoader.HadoopCatalogLoader
static class	CatalogLoader.HiveCatalogLoader

Method Summary

Modifier and Type	Method	Description
static CatalogLoader	custom(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> properties, org.apache.hadoop.conf.Configuration hadoopConf, java.lang.String impl)
static CatalogLoader	hadoop(java.lang.String name, org.apache.hadoop.conf.Configuration hadoopConf, java.util.Map<java.lang.String,java.lang.String> properties)
static CatalogLoader	hive(java.lang.String name, org.apache.hadoop.conf.Configuration hadoopConf, java.util.Map<java.lang.String,java.lang.String> properties)
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.util.Map<java.lang.String,java.lang.String> properties)

hive

static CatalogLoader hive(java.lang.String name,
                          org.apache.hadoop.conf.Configuration hadoopConf,
                          java.util.Map<java.lang.String,java.lang.String> properties)

custom

static CatalogLoader custom(java.lang.String name,
                            java.util.Map<java.lang.String,java.lang.String> properties,
                            org.apache.hadoop.conf.Configuration hadoopConf,
                            java.lang.String impl)