Skip to main content

Module compaction_resolver

risingwave_stream::executor::iceberg_with_pk_index

Module compaction_resolver 

Source

Structs§

CompactionResolverExecutor
Leaf executor for the iceberg pk-index coordinated compaction.

Functions§

collect_input_dvs 🔒
Walks the manifests of snapshot and collects, per input data file, the merged set of deleted positions from every live position-delete file referencing it.
pk_projection 🔒
Builds a projection for PK root columns and maps the projected physical order back to the downstream PK order.
scan_input_pks_at_positions 🔒
scan_output_file_inner 🔒
write_conflict_delete_files 🔒