[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950696#comment-16950696
]
Dian Fu commented on FLINK-7151:
--------------------------------
Supporting Python is very important for DDL. The very important info from the
DDL should be defined, whether it is Python UDF or not. I agree with [~twalthr]
that, we may support other languages i.e. JavaScript, Go, etc in the future. We
need to know the language during the implementation(not the API level), then we
can get the input types, result type and the other informations during the
implementation. So I think the design doc is better to consider how to support
multi-language, Python is one of the languages. (The difference is the
implementation logic for parsing the UDF definition information). Of course, we
can add more options in the DDL clause for the requirements, but I think we
don't want to make the DDL complex.
Looking forward to the discussion in the ML and willing to hear more
suggestions from the community.
> Add a basic function SQL DDL
> ----------------------------
>
> 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)
