[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401583#comment-16401583
]
Shuyi Chen commented on FLINK-7151:
-----------------------------------
Hi [~yinhua], I am actively working on a design doc for Flink SQL DDL.
Initially, I am planning to support :
CREATE TABLE
DROP TABLE
CREATE TYPE
DROP TYPE
CREATE LIBRARY
DROP LIBRARY
CREATE FUNCTION
DROP FUNCTION
I am currently working on the Calcite side ( TYPE DDL, LIBRARY DDL and FUNCTION
DDL) to come up with a proper DDL grammar, and add necessary functionality in
calcite core to support these DDLs in flink. I'll share the design doc soon
when it's ready.
> FLINK SQL support create temporary function and table
> -----------------------------------------------------
>
> Key: FLINK-7151
> URL: https://issues.apache.org/jira/browse/FLINK-7151
> Project: Flink
> Issue Type: New Feature
> Components: Table API & SQL
> Reporter: yuemeng
> Assignee: yuemeng
> Priority: Major
>
> Based on create temporary function and table.we can register a udf,udaf,udtf
> use sql:
> {code}
> CREATE TEMPORARY 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 message was sent by Atlassian JIRA
(v7.6.3#76005)
