Skip to main content

load_deletes

risingwave_connector::source::iceberg::update_planner

Function load_deletes 

Source 
async fn load_deletes(
    binding: &IcebergUpdateBinding,
    table: &Table,
    manifest_file: &ManifestFile,
    max_sequence: i64,
) -> ConnectorResult<Vec<(String, DeleteEntry)>>
Expand description

Live, validated delete descriptors of one delete manifest.