[ https://issues.apache.org/jira/browse/FLINK-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16414626#comment-16414626 ]
Shuyi Chen commented on FLINK-9049: ----------------------------------- Thanks a lot, [~twalthr]. Assigned [FLINK-8866|https://issues.apache.org/jira/browse/FLINK-8866] to me. > 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)