ivi-ru/flink-clickhouse-sink

how to process deletion on clickhouse

Closed this issue 2 years ago · 1 comments

baisui1981 commented 2 years ago

as checked the document of flink-clickhouse-sink ,I have a question how to execute deletion on Clickhouse , it seems that has not been mentioned

mchernyakov commented 2 years ago

@baisui1981 hi, flink-clickhouse-sink does not have such an option.
It works only with inserts, check here https://github.com/ivi-ru/flink-clickhouse-sink/blob/master/src/main/java/ru/ivi/opensource/flinkclickhousesink/applied/ClickHouseWriter.java#L198 .