Skip to main content

delete_tasks

risingwave_connector::source::iceberg::update_planner

Function delete_tasks 

Source 
fn delete_tasks(
    binding: Arc<IcebergUpdateBinding>,
    table: Table,
    cursor: IcebergUpdateCursor,
) -> Pin<Box<dyn Stream<Item = Result<IcebergUpdateTask, ConnectorError>> + Send>>
Expand description

Retained files are live in both snapshots, either moved between data manifests or kept in an unchanged one. The latter are looked up only when one of their delete artifacts changed. Removed files retract the rows visible in the parent.