Class CatalogUtils


  • public class CatalogUtils
    extends Object
    Rewrite to avoid using deprecated API.
    • Constructor Detail

      • CatalogUtils

        public CatalogUtils()
    • Method Detail

      • createCatalogTable

        public static org.apache.flink.table.catalog.CatalogTable createCatalogTable​(org.apache.flink.table.api.Schema schema,
                                                                                     List<String> partitionKeys,
                                                                                     Map<String,​String> options,
                                                                                     @Nullable
                                                                                     String comment)