Skip to main content

ensure_entry_fanout_task

query::dist_plan::remote_dyn_filter_registry

Function ensure_entry_fanout_task 

Source 
fn ensure_entry_fanout_task(
    query_id: QueryId,
    entry: Arc<DynFilterEntry>,
    region_query_handler: RegionQueryHandlerRef,
    lifecycle_rx: Receiver<()>,
)