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 & 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)
