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.

Type Aliases§

Cache 🔒