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)