Skip to main content

range_len

risingwave_connector::source::iceberg::update_planner

Function range_len 

Source 
fn range_len(pending: &[&SnapshotRef]) -> usize
Expand description

The number of pending snapshots planned as one range. A range ends before the next compaction, and a compaction forms a range of its own: it rewrites rows without changing them, while a net diff across it would retract and re-insert every rewritten row.