Skip to main content

insert_tasks

risingwave_connector::source::iceberg::update_planner

Function insert_tasks 

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

New files are live in added data manifests but not in removed ones. Files moved between data manifests are retained. Same-commit delete artifacts only filter Inserts.