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