如何在Flink中创建只读TableEnvironment?

问题描述

我们确实有一个应用程序,它从多个服务中获取sql请求,并使用Flink的TableEnvironment执行它们。我们确实希望对查询进行限制。基本上,我们只想允许SELECT查询,并禁用DROPDELETE等语句。

我们没有机会使用像Hive这样的metastore来做到这一点,我们可以使用Flink API来实现吗?

最好。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)