public static class CatalogLoader.CustomCatalogLoader extends java.lang.Object implements CatalogLoader
CatalogLoader.CustomCatalogLoader, CatalogLoader.HadoopCatalogLoader, CatalogLoader.HiveCatalogLoader, CatalogLoader.RESTCatalogLoader
Modifier and Type | Method and Description |
---|---|
CatalogLoader |
clone()
Clone a CatalogLoader.
|
Catalog |
loadCatalog()
Create a new catalog with the provided properties.
|
java.lang.String |
toString() |
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
custom, hadoop, hive, rest
public Catalog loadCatalog()
CatalogLoader
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.loadCatalog
in interface CatalogLoader
Catalog
public CatalogLoader clone()
CatalogLoader
clone
in interface CatalogLoader
clone
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object