Package org.apache.iceberg.flink
Class CatalogLoader.CustomCatalogLoader
- java.lang.Object
-
- org.apache.iceberg.flink.CatalogLoader.CustomCatalogLoader
-
- All Implemented Interfaces:
java.io.Serializable
,CatalogLoader
- Enclosing interface:
- CatalogLoader
public static class CatalogLoader.CustomCatalogLoader 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
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Catalog
loadCatalog()
Create a new catalog with the provided properties.java.lang.String
toString()
-
-
-
Method Detail
-
loadCatalog
public Catalog loadCatalog()
Description copied from interface:CatalogLoader
Create a new catalog with the provided properties. NOTICE: for flink, we may initialize theCatalogLoader
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.- Specified by:
loadCatalog
in interfaceCatalogLoader
- Returns:
- a newly created
Catalog
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-