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

  1. StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  2. StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
  4. // 加载 hive 模块
  5. tEnv.executeSql("LOAD MODULE hive WITH ('hive-version' = '3.1.2')");
  6. tEnv.executeSql("SHOW MODULES").print();
  7. // +-------------+
  8. // | module name |
  9. // +-------------+
  10. // |        core |
  11. // |        hive |
  12. // +-------------+

Scala

  1. val env = StreamExecutionEnvironment.getExecutionEnvironment()
  2. val tEnv = StreamTableEnvironment.create(env)
  4. // 加载 hive 模块
  5. tEnv.executeSql("LOAD MODULE hive WITH ('hive-version' = '3.1.2')")
  6. tEnv.executeSql("SHOW MODULES").print()
  7. // +-------------+
  8. // | module name |
  9. // +-------------+
  10. // |        core |
  11. // |        hive |
  12. // +-------------+

Python

  1. table_env = StreamTableEnvironment.create(...)
  3. # 加载 hive 模块
  4. table_env.execute_sql("LOAD MODULE hive WITH ('hive-version' = '3.1.2')")
  5. table_env.execute_sql("SHOW MODULES").print()
  6. # +-------------+
  7. # | module name |
  8. # +-------------+
  9. # |        core |
  10. # |        hive |
  11. # +-------------+

SQL CLI

  1. Flink SQL> LOAD MODULE hive WITH ('hive-version' = '3.1.2');
  2. [INFO] Load module succeeded!
  4. Flink SQL> SHOW MODULES;
  5. +-------------+
  6. | module name |
  7. +-------------+
  8. |        core |
  9. |        hive |
  10. +-------------+

LOAD MODULE

以下语法概述了可用的语法规则：

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

module_name 是一个简单的标识符。它是区分大小写的，由于它被用于执行模块发现，因此也要与模块工厂（module factory）中定义的模块类型相同。属性 ('key1' = 'val1', 'key2' = 'val2', ...) 是一个 map 结构，它包含一组键值对（不包括 ‘type’ 的键），这些属性会被传递给模块发现服务以实例化相应的模块。