Interface CatalogLoader

    • Method Detail

      • loadCatalog

        Catalog loadCatalog()
        Create a new catalog with the provided properties. NOTICE: for flink, we may initialize the 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.
        Returns:
        a newly created Catalog
      • hadoop

        static CatalogLoader hadoop​(java.lang.String name,
                                    org.apache.hadoop.conf.Configuration hadoopConf,
                                    java.util.Map<java.lang.String,​java.lang.String> properties)
      • hive

        static CatalogLoader hive​(java.lang.String name,
                                  org.apache.hadoop.conf.Configuration hadoopConf,
                                  java.util.Map<java.lang.String,​java.lang.String> properties)
      • custom

        static CatalogLoader custom​(java.lang.String name,
                                    java.util.Map<java.lang.String,​java.lang.String> properties,
                                    org.apache.hadoop.conf.Configuration hadoopConf,
                                    java.lang.String impl)