Trait PhysicalPlanWrapper

pub trait PhysicalPlanWrapper:
    Send
    + Sync
    + 'static {
    // Required method
    fn wrap(
        &self,
        origin: Arc<dyn ExecutionPlan>,
        ctx: QueryContextRef,
    ) -> Arc<dyn ExecutionPlan>;
}

wrap physical plan with additional layer e.g: metrics retrieving layer upon physical plan

Required Methods

fn wrap( &self, origin: Arc<dyn ExecutionPlan>, ctx: QueryContextRef, ) -> Arc<dyn ExecutionPlan>

Implementors