사용자 정의 함수
사용자 정의 함수 (User-Defined Functions)
Flink SQL은 내장 기능을 확장하기 위해 사용자 정의 함수(UDF)를 지원합니다. 스칼라 함수, 테이블 함수, 집계 함수를 직접 만들어 SQL 쿼리에서 사용할 수 있습니다.
출처: 문서
본문
Flink SQL은 내장 기능을 확장하기 위해 사용자 정의 함수(UDF)를 지원합니다. 스칼라 함수, 테이블 함수, 그리고 집계 함수를 만들어 SQL 쿼리에서 사용할 수 있습니다.
SQL에서 UDF 등록하기
UDF를 개발한 뒤에는 CREATE FUNCTION 문을 사용해 SQL에서 등록할 수 있습니다:
CREATE FUNCTION myudf AS 'com.example.MyScalarFunction';
전체 문법은 CREATE FUNCTION 문서를 참고하세요.
UDF 개발하기
사용자 정의 함수를 작성하려면 Java, Scala, 또는 Python 프로그래밍이 필요합니다. UDF를 개발하는 자세한 방법은 Table API 문서를 참고하세요:
- User-Defined Functions 개요: 스칼라, 테이블, 집계 함수를 구현하고 등록하는 방법.
- Process Table Functions: 복잡한 이벤트 처리를 위한 고급 테이블 함수.