flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Zhenqiu Huang (Jira)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-7151) Add create and drop function DDL in SQL Parser
Date Mon, 18 Nov 2019 08:14:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Zhenqiu Huang updated FLINK-7151:
---------------------------------
    Summary: Add create and drop function DDL in SQL Parser  (was: Add a basic function SQL
DDL)

> Add create and drop function DDL in SQL Parser
> ----------------------------------------------
>
>                 Key: FLINK-7151
>                 URL: https://issues.apache.org/jira/browse/FLINK-7151
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Table SQL / API
>            Reporter: yuemeng
>            Assignee: Zhenqiu Huang
>            Priority: Critical
>              Labels: pull-request-available
>             Fix For: 1.10.0
>
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> Based on create function and table.we can register a udf,udaf,udtf use sql:
> {code}
> 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;
> {code}
> {code}
> 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;
> {code}
> 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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message