This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.
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
UNLOAD MODULE #
以下语法概述了可用的语法规则:
UNLOAD MODULE module_name