flink-connector-clickhouse
flink-connector-clickhouse copied to clipboard
Proposal to use ReplacingMergeTree for handling updates/deletes.
We have an implemention in the https://github.com/Altinity/clickhouse-sink-connector Kafka sink connector where updates/deletes are handled in ReplacingMergeTree.
Deletes can be handled on the newer ReplacingMergeTree with the is_deleted
column.
Happy to submit PR.
@subkanthi Thank you, I will study it.