You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "yuemeng (JIRA)" <ji...@apache.org> on 2017/07/11 09:30:00 UTC
[jira] [Comment Edited] (FLINK-7148) Flink SQL API support DDL
[ https://issues.apache.org/jira/browse/FLINK-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081965#comment-16081965 ]
yuemeng edited comment on FLINK-7148 at 7/11/17 9:29 AM:
---------------------------------------------------------
[~jark]
[~fhueske]
this is duplicate with FLINK-6962,i will close this issue.
was (Author: yuemeng):
[~jark]
[~fhueske]
this is duplicate with FLINK-6962,i wil close this issue.
> Flink SQL API support DDL
> --------------------------
>
> Key: FLINK-7148
> URL: https://issues.apache.org/jira/browse/FLINK-7148
> Project: Flink
> Issue Type: New Feature
> Components: Table API & SQL
> Reporter: yuemeng
> Priority: Critical
>
> For now,Flink SQL can't support DDL operation,user can only register a table by call registerTableInternal in TableEnvironment. we should support DDL such as create table or create function like:
> {code}
> CREATE TABLE kafka_source (
> id INT,
> price INT
> ) PROPERTIES (
> category = 'source',
> type = 'kafka',
> version = '0.9.0.1',
> separator = ',',
> topic = 'test',
> brokers = 'xxxx:9092',
> group_id = 'test'
> );
> CREATE TABLE db_sink (
> id INT,
> price DOUBLE
> ) PROPERTIES (
> category = 'sink',
> type = 'mysql',
> table_name = 'udaf_test',
> url = 'jdbc:mysql://127.0.0.1:3308/ds?useUnicode=true&characterEncoding=UTF8',
> username = 'ds_dev',
> password = 's]k51_(>R'
> );
> CREATE TEMPORARY function 'AVGUDAF' AS 'com.xxxx.server.codegen.aggregate.udaf.avg.IntegerAvgUDAF';
> INSERT INTO db_sink SELECT id ,AVGUDAF(price) FROM kafka_source group by id
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)