Package org.apache.iceberg.flink
Class CatalogLoader.HadoopCatalogLoader
- java.lang.Object
 - 
- org.apache.iceberg.flink.CatalogLoader.HadoopCatalogLoader
 
 
- 
- All Implemented Interfaces:
 java.io.Serializable,java.lang.Cloneable,CatalogLoader
- Enclosing interface:
 - CatalogLoader
 
public static class CatalogLoader.HadoopCatalogLoader 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
 
 - 
 
 -