UNLOAD 문
UNLOAD 문 (UNLOAD Statements)
UNLOAD 문은 내장 또는 사용자 정의 모듈을 언로드하는 데 사용합니다. UNLOAD MODULE 문법으로 특정 모듈을 세션에서 제거할 수 있습니다.
출처: 문서
본문
UNLOAD 문은 내장 또는 사용자 정의 모듈을 언로드하는 데 사용합니다.
UNLOAD 문 실행 (Run a UNLOAD statement)
UNLOAD 문은 TableEnvironment의 executeSql() 메서드로 실행할 수 있습니다. executeSql() 메서드는 성공적인 UNLOAD 연산에 대해 'OK'를 반환하며, 그렇지 않으면 예외를 던집니다. 다음 예시는 TableEnvironment에서 UNLOAD 문을 실행하는 방법을 보여줍니다.
SQL CLI에서는 UNLOAD 문을 SQL CLI에서 실행할 수 있습니다. 다음 예시는 SQL CLI에서 UNLOAD 문을 실행하는 방법을 보여줍니다.
Java:
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
// unload a core module
tEnv.executeSql("UNLOAD MODULE core");
tEnv.executeSql("SHOW MODULES").print();
// Empty set
Scala:
val env = StreamExecutionEnvironment.getExecutionEnvironment()
val tEnv = StreamTableEnvironment.create(env)
// unload a core module
tEnv.executeSql("UNLOAD MODULE core")
tEnv.executeSql("SHOW MODULES").print()
// Empty set
Python:
table_env = StreamTableEnvironment.create(...)
# unload a core module
table_env.execute_sql("UNLOAD MODULE core")
table_env.execute_sql("SHOW MODULES").print()
# Empty set
SQL CLI:
Flink SQL> UNLOAD MODULE core;
[INFO] Unload module succeeded!
Flink SQL> SHOW MODULES;
Empty set
UNLOAD MODULE
다음 문법은 사용 가능한 문법의 개요를 제공합니다:
UNLOAD MODULE module_name