Skip to main content

SINK_USER_PRESERVE_ROW_LEVEL_CHANGES

Constant SINK_USER_PRESERVE_ROW_LEVEL_CHANGES 

Source
pub const SINK_USER_PRESERVE_ROW_LEVEL_CHANGES: &str = "preserve_row_level_changes";
Expand description

When enabled, the sink executor preserves distinct upstream stream-key changes that map to the same downstream primary key instead of compacting them into one final-state update within a barrier. Upstream changes under the same stream key may still be compacted earlier.