[jira] [Created] (FLINK-18613) How to support retract & upsert sink for a TableSink ?

[Shang Yuanchun (Jira)]

hehuiyuan created FLINK-18613:
---------------------------------

             Summary: How to support retract & upsert sink for a TableSink ?
                 Key: FLINK-18613
                 URL: https://issues.apache.org/jira/browse/FLINK-18613
             Project: Flink
          Issue Type: Wish
          Components: Table SQL / Planner
            Reporter: hehuiyuan


Environment : FLink 1.9 / Blink planner

Hi , i want to ask a question :

I have a job that executes multiple sql and a TableSink class:

(1) insert into table_0 select count(*) from table1;

(2)insert into table_2 select name, sum(score) form table1 group by name;

 

The TableSink implements UpsertStreamTablesink interface.

That is ok for SQL (2), but is not suppported for SQL (1) which there are not keys.

 

But i want to use a TableSink which can support the upsert and retract , can you give me some advices?   ~ Thanks.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)