Flink应用开发系列（六十三）Table SQL开发之load函数和unload函数

在flink table sql中我们还有一些场景，例如我们要在flink中对接hive执行相关的sql信息，此时就需要把hive的模块给引入进来，就需要使用到load函数，整个load函数的基础语法如下：

LOAD MODULE module_name [WITH ('key1' = 'val1', 'key2' = 'val2', ...)]

例如这里我们引入hive的moduel，那么需要执行的load语句是：

LOAD MODULE hive WITH ('hive-version' = '3.1.3');

执行完毕之后，load模块就加载进来了，示例图如下：

备注：

1、这里引入hive的module的时候，需要在flink的执行环境添加相关的依赖包，依赖包列表如下：

当然除了load函数之后，那么肯定就有对应的函数unload，load是加载，unload就是卸载。此时我们如果想要卸载掉unload的话，可以使用如下的语句：

unload moduel hive

执行完毕之后，我们在查看所有的module，就会发现hive已经不存在了。