Skip to main content

load

介绍

LOAD语句用于加载内置或用户自定义的模块。

LOAD模块

语法结构:

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

module_name是一个简单的标识符,区分大小写。它应该与模块工厂中定义的模块类型相同,其用于模块的发现。

properties ('key1' = 'val1', 'key2' = 'val2',…)是一个映射,包含一组键值对(除了key 'type'),传递给发现服务相对应的模块。

案例代码

-- 加载 hive 模块
load module hive with ('hive-version' = '2.3.6');
-- 推荐下面这种写法,不指定 hive 的版本,由系统去自动提取。
load module hive;

给平台添加了 flink-connector-sql-hive 依赖之后,就相当于已经添加了 hive 模块的实现,因此可以直接去加载 hive 模块。

flink sql 中加载了hive模块,并且usehive模块之后,查询语句中就可以直接去使用hive中的函数了。