Package org.apache.iceberg.flink
Class CatalogLoader.HiveCatalogLoader
- java.lang.Object
- 
- org.apache.iceberg.flink.CatalogLoader.HiveCatalogLoader
 
- 
- All Implemented Interfaces:
- java.io.Serializable,- 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.CatalogLoaderCatalogLoader.CustomCatalogLoader, CatalogLoader.HadoopCatalogLoader, CatalogLoader.HiveCatalogLoader
 
- 
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description CatalogloadCatalog()Create a new catalog with the provided properties.java.lang.StringtoString()
 
- 
- 
- 
Method Detail- 
loadCatalogpublic 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 interface- CatalogLoader
- Returns:
- a newly created Catalog
 
 - 
toStringpublic java.lang.String toString() - Overrides:
- toStringin class- java.lang.Object
 
 
- 
 
-