Module planner

Custom planners for datafusion so that you can convert custom nodes, can be used to trace custom metrics in an operation

Example

#[derive(Clone)] struct MergeMetricExtensionPlanner {}

#[async_trait] impl ExtensionPlanner for MergeMetricExtensionPlanner { async fn plan_extension( &self, planner: &dyn PhysicalPlanner, node: &dyn UserDefinedLogicalNode, _logical_inputs: &[&LogicalPlan], physical_inputs: &Arc, session_state: &SessionState, ) -> DataFusionResult<Option<Arc>> {}

let merge_planner = DeltaPlanner:: { extension_planner: MergeMetricExtensionPlanner {} };

let state = state.with_query_planner(Arc::new(merge_planner));

Structs

• DeltaPlanner
  Deltaplanner