Skip to main content

delete_change

risingwave_connector::source::iceberg::update_planner

Function delete_change 

Source 
fn delete_change(
    binding: &Arc<IcebergUpdateBinding>,
    cursor: &IcebergUpdateCursor,
    file: UpdateFile,
    parent: &BTreeMap<String, DeleteEntry>,
    current: &BTreeMap<String, DeleteEntry>,
) -> ConnectorResult<Option<IcebergUpdateTask>>