LOAD 语句
LOAD 语句用于加载内置的或用户自定义的模块。
执行 LOAD 语句
Java
可以使用 TableEnvironment
的 executeSql()
方法执行 LOAD 语句。如果 LOAD 操作执行成功,executeSql()
方法会返回 ‘OK’,否则会抛出异常。
以下示例展示了如何在 TableEnvironment
中执行一条 LOAD 语句。
Scala
可以使用 TableEnvironment
的 executeSql()
方法执行 LOAD 语句。如果 LOAD 操作执行成功,executeSql()
方法会返回 ‘OK’,否则会抛出异常。
以下示例展示了如何在 TableEnvironment
中执行一条 LOAD 语句。
Python
可以使用 TableEnvironment
的 execute_sql()
方法执行 LOAD 语句。如果 LOAD 操作执行成功,execute_sql()
方法会返回 ‘OK’,否则会抛出异常。
以下示例展示了如何在 TableEnvironment
中执行一条 LOAD 语句。
SQL CLI
LOAD 语句可以在 SQL CLI 中执行。
以下示例展示了如何在 SQL CLI 中执行一条 LOAD 语句。
Java
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
// 加载 hive 模块
tEnv.executeSql("LOAD MODULE hive WITH ('hive-version' = '3.1.3')");
tEnv.executeSql("SHOW MODULES").print();
// +-------------+
// | module name |
// +-------------+
// | core |
// | hive |
// +-------------+
Scala
val env = StreamExecutionEnvironment.getExecutionEnvironment()
val tEnv = StreamTableEnvironment.create(env)
// 加载 hive 模块
tEnv.executeSql("LOAD MODULE hive WITH ('hive-version' = '3.1.3')")
tEnv.executeSql("SHOW MODULES").print()
// +-------------+
// | module name |
// +-------------+
// | core |
// | hive |
// +-------------+
Python
table_env = StreamTableEnvironment.create(...)
# 加载 hive 模块
table_env.execute_sql("LOAD MODULE hive WITH ('hive-version' = '3.1.3')")
table_env.execute_sql("SHOW MODULES").print()
# +-------------+
# | module name |
# +-------------+
# | core |
# | hive |
# +-------------+
SQL CLI
Flink SQL> LOAD MODULE hive WITH ('hive-version' = '3.1.3');
[INFO] Load module succeeded!
Flink SQL> SHOW MODULES;
+-------------+
| module name |
+-------------+
| core |
| hive |
+-------------+
LOAD MODULE
以下语法概述了可用的语法规则:
LOAD MODULE module_name [WITH ('key1' = 'val1', 'key2' = 'val2', ...)]
module_name
是一个简单的标识符。它是区分大小写的,由于它被用于执行模块发现,因此也要与模块工厂(module factory)中定义的模块类型相同。属性('key1' = 'val1', 'key2' = 'val2', ...)
是一个 map 结构,它包含一组键值对(不包括 ’type’ 的键),这些属性会被传递给模块发现服务以实例化相应的模块。