Skip to main content

current_stable_snapshot

query::dist_plan::remote_dyn_filter_registry

Function current_stable_snapshot 

Source 
async fn current_stable_snapshot(
    filter: &DynamicFilterPhysicalExpr,
    lifecycle_rx: &mut Receiver<()>,
) -> Option<(u64, Arc<dyn PhysicalExpr>)>