risingwave_stream::executor::dedup

Module append_only_dedup

Source

Structsยง

AppendOnlyDedupExecutor
AppendOnlyDedupExecutor drops any message that has duplicate pk columns with previous messages. It only accepts append-only input, and its output will be append-only as well.