我们知道flink中有几种catalog,一种是内存的 默认有一个default_catalog;再一个是jdbc的,还有一个是hive;下面介绍一下如何通过sql语句实现创建一个内存中的catalog。
CREATE CATALOG test_catalog WITH (
'type'='generic_in_memory'
);创建完成以后可以使用show catalog来查询;
show catalogs;
最后如何使用catalogs呢,跟以往的不同,不能通过.的形式进行调用,只能使用 use catalog test_catalog 这样来操作。
执行以后就可以对这个catalog下面的 database 和 tables进行操作了。
不过这样有一个问题,如何让一个sql语句中执行不同catalog和database下的表呢?
后续有解决方案再进行更新。
版权声明:本文为yfqfy原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。