Skip to main content

attached_deletes

risingwave_connector::source::iceberg::update_planner

Function attached_deletes 

Source 
fn attached_deletes(
    file: &UpdateFile,
    delete: Option<&DeleteEntry>,
) -> ConnectorResult<Vec<FileScanTaskDeleteFile>>