[FLINK-7151] Support function DDL

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: Table SQL / API
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-available
• Assignee: Zhenqiu Huang
• Reporter: yuemeng
• Created: 11/Jul/17 11:09
• Updated: 01/Apr/24 16:01
• Resolved: 01/Apr/24 16:01

Description

Based on create function and table.we can register a udf,udaf,udtf use sql:

CREATE FUNCTION [IF NOT EXISTS] [catalog_name.db_name.]function_name AS class_name;
DROP FUNCTION [IF EXISTS] [catalog_name.db_name.]function_name;
ALTER FUNCTION [IF EXISTS] [catalog_name.db_name.]function_name RENAME TO new_name;

CREATE function 'TOPK' AS 'com.xxxx.aggregate.udaf.distinctUdaf.topk.ITopKUDAF';
INSERT INTO db_sink SELECT id, TOPK(price, 5, 'DESC') FROM kafka_source GROUP BY id;

This ticket can assume that the function class is already loaded in classpath by users. Advanced syntax like to how to dynamically load udf libraries from external locations can be on a separate ticket.

Issue Links

• blocks: FLINK-14055 Add advanced function DDL syntax "USING JAR"
• is a child of: FLINK-10232 Add a SQL DDL
• is a parent of: FLINK-14711 Add Alter Function and Show Functions in SQL Parser
• is blocked by: FLINK-14711 Add Alter Function and Show Functions in SQL Parser
• relates to: FLINK-14837 Support Function DDL in TableEnvironment
• links to: Flink SQL DDL design doc
• links to: GitHub Pull Request #9689
• links to: GitHub Pull Request #10234

Sub-Tasks

• Support Function DDL in TableEnvironment: Reopened
• Add create and drop function DDL in parser: Closed
• Add Alter Function and Show Functions in SQL Parser: Closed
• create and drop temp system functions from DDL to FunctionCatalog: Closed
• create and drop temp catalog functions from DDL to FunctionCatalog: Closed
• register, drop, and alter catalog functions from DDL via catalog: Closed
• refactor CatalogFunction interface and impls to remove properties map: Closed
• refactor CatalogFunction interface and impls to add language field: Closed
• add documentation and example for function DDL: Closed
• migrate "show functions" from sql cli to sql parser: Closed
• rename CreateFunctionOperation, DropFunctionOperation, AlterFunctionOperation to CreateCatalogFunctionOperation, DropCatalogFunctionOperation, AlterCatalogFunctionOperation: Closed