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

["Timo Walther (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timo Walther closed FLINK-9049.
-------------------------------
    Resolution: Duplicate

This is duplicate of FLINK-8866. So let's continue the discussion there. I assigned FLINK-8866 to me but haven't started with it. [~suez1224] feel free to assign it to you.

> 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 & SQL
>            Reporter: Shuyi Chen
>            Assignee: Shuyi Chen
>            Priority: Major
>
> 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].
> Below are a few major changes in mind. 
> 1) Add TableSinkFactory/TableSinkFactoryService similar to TableSourceFactory/TableSourceFactoryService
> 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)