Flink Table & SQL Catalog 及DataStream、Table相互轉換

Catalog維護了Flink Table和SQL中的元數據,如Database、Table、View、UDF等。java Catalog類型 GenericInMemoryCatalog: 內置Catalog。名爲default_catalog,默認數據庫名爲default_database。默認,如用TableEnvironment#registerTable註冊的表,均會註冊到這個Catal
相關文章
相關標籤/搜索