UNLOAD 语句

UNLOAD 语句 #

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

执行 UNLOAD 语句 #

可以使用 TableEnvironment 的 executeSql() 方法执行 UNLOAD 语句。如果 UNLOAD 操作执行成功，executeSql() 方法会返回 ‘OK’，否则会抛出异常。

以下示例展示了如何在 TableEnvironment 中执行一条 UNLOAD 语句。

可以使用 TableEnvironment 的 executeSql() 方法执行 UNLOAD 语句。如果 UNLOAD 操作执行成功，executeSql() 方法会返回 ‘OK’，否则会抛出异常。

以下示例展示了如何在 TableEnvironment 中执行一条 UNLOAD 语句。

可以使用 TableEnvironment 的 execute_sql() 方法执行 UNLOAD 语句。如果 UNLOAD 操作执行成功，execute_sql() 方法会返回 ‘OK’，否则会抛出异常。

以下示例展示了如何在 TableEnvironment 中执行一条 UNLOAD 语句。

UNLOAD 语句可以在 SQL CLI 中执行。

以下示例展示了如何在 SQL CLI 中执行一条 UNLOAD 语句。

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);  // 卸载 core 模块 tEnv.executeSql("UNLOAD MODULE core"); tEnv.executeSql("SHOW MODULES").print(); // Empty set 
val env = StreamExecutionEnvironment.getExecutionEnvironment() val tEnv = StreamTableEnvironment.create(env)  // 卸载 core 模块 tEnv.executeSql("UNLOAD MODULE core") tEnv.executeSql("SHOW MODULES").print() // Empty set 
table_env = StreamTableEnvironment.create(...)  # 卸载 core 模块 table_env.execute_sql("UNLOAD MODULE core") table_env.execute_sql("SHOW MODULES").print() # Empty set 
Flink SQL> UNLOAD MODULE core; [INFO] Unload module succeeded!  Flink SQL> SHOW MODULES; Empty set

Back to top

UNLOAD MODULE #

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

UNLOAD MODULE module_name