JAR 문
JAR 문 (JAR Statements)
JAR 문은 런타임에서 사용자 jar를 클래스패스에 추가하거나, 클래스패스에서 제거하거나, 클래스패스에 추가된 jar를 보여주는 데 사용돼요. Flink SQL은 현재 ADD JAR, SHOW JARS, REMOVE JAR 문을 지원해요.
출처: 문서
본문
Flink SQL은 현재 다음 JAR 문을 지원해요:
- ADD JAR
- SHOW JARS
- REMOVE JAR
JAR 문 실행하기 (Run a JAR statement)
다음 예제는 SQL CLI에서 JAR 문을 실행하는 방법을 보여줘요:
Flink SQL> ADD JAR '/path/hello.jar';
[INFO] Execute statement succeeded.
Flink SQL> ADD JAR 'hdfs:///udf/common-udf.jar';
[INFO] Execute statement succeeded.
Flink SQL> SHOW JARS;
+----------------------------+
| jars |
+----------------------------+
| /path/hello.jar |
| hdfs:///udf/common-udf.jar |
+----------------------------+
Flink SQL> REMOVE JAR '/path/hello.jar';
[INFO] The specified jar is removed from session classloader.
ADD JAR
ADD JAR '<path_to_filename>.jar'
리소스 목록에 JAR 파일을 추가해요. 로컬 또는 원격 파일 시스템에 있는 jar 추가를 지원해요. 추가된 JAR 파일은 SHOW JARS 문으로 나열할 수 있어요.
제약 (Limitation)
Hive 소스/싱크/함수/카탈로그를 로드하는 데 ADD JAR 문을 사용하지 마세요. 이는 Hive 커넥터의 알려진 제약이며 향후 버전에서 수정될 예정이에요. 현재는 이 지침에 따라 Hive 통합을 설정하는 것이 권장돼요.
SHOW JARS
SHOW JARS
ADD JAR 문으로 추가된 모든 jar를 보여줘요.
REMOVE JAR
REMOVE JAR '<path_to_filename>.jar'
ADD JAR 문으로 추가된 지정 jar를 제거해요.
주의: REMOVE JAR 문은 SQL CLI에서만 동작해요.