Skip to main content

fanout_snapshot_for_query

query::dist_plan::remote_dyn_filter_registry

Function fanout_snapshot_for_query 

Source 
async fn fanout_snapshot_for_query(
    query_id: QueryId,
    region_query_handler: &RegionQueryHandlerRef,
    entry: &DynFilterEntry,
    filter: &DynamicFilterPhysicalExpr,
    is_complete: bool,
    lifecycle_rx: &mut Receiver<()>,
    control_rpc_timeout: Duration,
) -> bool