public interface CatalogLoader
extends java.io.Serializable, java.lang.Cloneable
Catalog
.Modifier and Type | Interface and Description |
---|---|
static class |
CatalogLoader.CustomCatalogLoader |
static class |
CatalogLoader.HadoopCatalogLoader |
static class |
CatalogLoader.HiveCatalogLoader |
static class |
CatalogLoader.RESTCatalogLoader |
Modifier and Type | Method and Description |
---|---|
CatalogLoader |
clone()
Clone a CatalogLoader.
|
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) |
Catalog loadCatalog()
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.Catalog
CatalogLoader clone()
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)
static CatalogLoader rest(java.lang.String name, org.apache.hadoop.conf.Configuration hadoopConf, java.util.Map<java.lang.String,java.lang.String> properties)
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)