Package org.apache.iceberg.flink
Interface CatalogLoader
-
- All Superinterfaces:
java.io.Serializable
- All Known Implementing Classes:
CatalogLoader.CustomCatalogLoader
,CatalogLoader.HadoopCatalogLoader
,CatalogLoader.HiveCatalogLoader
,CatalogLoader.RESTCatalogLoader
public interface CatalogLoader extends java.io.Serializable
Serializable loader to load an IcebergCatalog
.
-
-
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
All Methods Static Methods Instance Methods Abstract Methods 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.static CatalogLoader
rest(java.lang.String name, org.apache.hadoop.conf.Configuration hadoopConf, java.util.Map<java.lang.String,java.lang.String> properties)
-
-
-
Method Detail
-
loadCatalog
Catalog loadCatalog()
Create a new catalog with the provided properties. NOTICE: for flink, we may initialize theCatalogLoader
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)
-
rest
static CatalogLoader rest(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)
-
-