Skip to main content

validate_position_delete_descriptor

risingwave_connector::sink::iceberg::position_delete

Function validate_position_delete_descriptor 

Source 
pub(crate) fn validate_position_delete_descriptor(
    delete: &FileScanTaskDeleteFile,
    data_file_path: &str,
) -> Result<Option<(u64, u64)>>
Expand description

Metadata-only source checks, shared by planning (including compaction) and replay reads. Returns the validated blob range for Puffin, or None for Parquet.