Danny Chen created HUDI-1738:
--------------------------------

             Summary: Emit deletes for Flink MOR table streaming read
                 Key: HUDI-1738
                 URL: https://issues.apache.org/jira/browse/HUDI-1738
             Project: Apache Hudi
          Issue Type: New Feature
          Components: Flink Integration
            Reporter: Danny Chen
            Assignee: Danny Chen
             Fix For: 0.9.0


Current we did a soft delete for DELETE row data when writes into hoodie table. 
For streaming read of MOR table, the Flink reader detects the delete records 
and still emit them if the record key semantics are still kept.

This is useful and actually a must for streaming ETL pipeline incremental 
computation. 



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

Reply via email to