You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/03/16 08:21:00 UTC
[jira] [Comment Edited] (FLINK-7151) FLINK SQL support create
temporary function and table
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401583#comment-16401583 ]
Shuyi Chen edited comment on FLINK-7151 at 3/16/18 8:20 AM:
------------------------------------------------------------
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.
was (Author: suez1224):
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)