Skip to main content

cancel_iceberg_task

risingwave_storage::hummock::compactor

Function cancel_iceberg_task 

Source 
fn cancel_iceberg_task(
    task_id: IcebergCompactionTaskId,
    task_queue: &mut IcebergTaskQueue,
    shutdown_map: &Arc<Mutex<HashMap<(IcebergCompactionTaskId, usize), Sender<()>>>>,
    task_trackers: &mut HashMap<IcebergCompactionTaskId, IcebergTaskTracker>,
)