Skip to main content

task

risingwave_connector::source::iceberg::update_planner

Function task 

Source 
fn task(
    binding: &Arc<IcebergUpdateBinding>,
    cursor: &IcebergUpdateCursor,
    file: UpdateFile,
    parent_deletes: Vec<FileScanTaskDeleteFile>,
    removed: bool,
) -> IcebergUpdateTask