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/21 20:12:00 UTC

[jira] [Created] (FLINK-9049) Create unified interfaces to configure and instatiate TableSink

Shuyi Chen created FLINK-9049:
---------------------------------

             Summary: Create unified interfaces to configure and instatiate TableSink
                 Key: FLINK-9049
                 URL: https://issues.apache.org/jira/browse/FLINK-9049
             Project: Flink
          Issue Type: Task
          Components: Table API &amp; SQL
            Reporter: Shuyi Chen
            Assignee: Shuyi Chen


This is a similar effort to [FLINK-8240|https://issues.apache.org/jira/browse/FLINK-8240], we want to create a unified interface for discovery and instantiation of TableSink, and later support table DDL in flink. The proposed solution would use similar approach in [FLINK-8240|https://issues.apache.org/jira/browse/FLINK-8240], and can re-use most of the implementations already done in [FLINK-8240|https://issues.apache.org/jira/browse/FLINK-8240].

1) Add TableSinkFactory{Service} similar to TableSourceFactory{Service]
2) Add a common property called "tableType" with values (source, sink and both) for both TableSource and TableSink.
3) in yaml file, replace "sources" with "tables", and use tableType to identify whether it's source or sink.





--
This message was sent by Atlassian JIRA
(v7.6.3#76005)