[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076093#comment-17076093 ] Timo Walther commented on FLINK-8545: - Big parts of this issue will be implemented by FLIP-95:

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057437#comment-17057437 ] Aljoscha Krettek commented on FLINK-8545: - [~enricoc] For reference, the modern work on this is

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933921#comment-16933921 ] Hequn Cheng commented on FLINK-8545: Hi [~enricoc], yes this feature is still be considered. Some

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933807#comment-16933807 ] Enrico Canzonieri commented on FLINK-8545: -- Is this ticket still being considered? Being able to

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579899#comment-16579899 ] Hequn Cheng commented on FLINK-8545: [~pnowojski] Great to have your response. The

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579726#comment-16579726 ] Piotr Nowojski commented on FLINK-8545: --- This `AppendStreamTable` would still carry on deletes

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576235#comment-16576235 ] Hequn Cheng commented on FLINK-8545: [~pnowojski] Hi, current design is to add an

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16575906#comment-16575906 ] Piotr Nowojski commented on FLINK-8545: --- Hi [~hequn8128], could you share the idea how are you

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16569121#comment-16569121 ] Hequn Cheng commented on FLINK-8545: [~elevy] Hi, sorry about the delay. It's almost halfway done. I

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16569040#comment-16569040 ] Elias Levy commented on FLINK-8545: --- [~hequn8128] are you still working on this feature? > Implement

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493096#comment-16493096 ] Hequn Cheng commented on FLINK-8545: Hi [~pnowojski], plan to work on it and probably will finish the

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492699#comment-16492699 ] Piotr Nowojski commented on FLINK-8545: --- [~hequn8128], could say what's the status of your work

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16353983#comment-16353983 ] Fabian Hueske commented on FLINK-8545: -- Hi [~hequn8128], yes. That sounds good :-) > Implement

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16353838#comment-16353838 ] Hequn Cheng commented on FLINK-8545: Hi, [~fhueske], I think you are right. For deletions on

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350548#comment-16350548 ] Hequn Cheng commented on FLINK-8545: Hi, the {{Tuple}} input format is a good choice. It is consistent

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349962#comment-16349962 ] Fabian Hueske commented on FLINK-8545: -- Yes, you are right. We also need to support a deletion flag.

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349724#comment-16349724 ] Hequn Cheng commented on FLINK-8545: Hi, [~fhueske]  Great to hear your suggestions. I agree with you,

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16348675#comment-16348675 ] Fabian Hueske commented on FLINK-8545: -- Yes, many user have been asking for this feature recently.