Package org.apache.iceberg.flink
Class CatalogLoader.HiveCatalogLoader
- java.lang.Object
-
- org.apache.iceberg.flink.CatalogLoader.HiveCatalogLoader
-
- All Implemented Interfaces:
java.io.Serializable,java.lang.Cloneable,CatalogLoader
- Enclosing interface:
- CatalogLoader
public static class CatalogLoader.HiveCatalogLoader extends java.lang.Object implements CatalogLoader
- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.iceberg.flink.CatalogLoader
CatalogLoader.CustomCatalogLoader, CatalogLoader.HadoopCatalogLoader, CatalogLoader.HiveCatalogLoader, CatalogLoader.RESTCatalogLoader
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CatalogLoaderclone()Clone a CatalogLoader.CatalogloadCatalog()Create a new catalog with the provided properties.java.lang.StringtoString()
-
-
-
Method Detail
-
loadCatalog
public Catalog loadCatalog()
Description copied from interface:CatalogLoaderCreate a new catalog with the provided properties. NOTICE: for flink, we may initialize theCatalogLoaderat 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.- Specified by:
loadCatalogin interfaceCatalogLoader- Returns:
- a newly created
Catalog
-
clone
public CatalogLoader clone()
Description copied from interface:CatalogLoaderClone a CatalogLoader.- Specified by:
clonein interfaceCatalogLoader- Overrides:
clonein classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-