Struct DataFusionDistributedPlanner 

pub struct DataFusionDistributedPlanner { /* private fields */ }

Lowers a DataFusion datafusion::logical_expr::LogicalPlan onto tablets.

Conversion is two-phase: the DataFusion tree is reduced to LogicalPlanLite, then distribute places fragments. Filters and projections are pushed onto base scans; residual filters that cannot be pushed are rejected rather than stringified without worker evaluation.

Implementations

impl DataFusionDistributedPlanner

pub fn new(query_id: QueryId) -> Self

Planner pinned to one query id with default options.

pub fn with_options(query_id: QueryId, options: PlannerOptions) -> Self

Planner with explicit fragment/join tuning.

pub fn query_id(&self) -> QueryId

Query id this planner stamps onto every plan.

pub fn lower( &self, plan: &LogicalPlan, locator: &dyn TabletLocator, metadata: &dyn ClusterMetadata, ) -> DistributedResult<DistributedPlan>

Lowers plan into a DistributedPlan against the given locator and control-plane metadata.

pub fn to_lite(&self, plan: &LogicalPlan) -> DistributedResult<LogicalPlanLite>

Converts a DataFusion logical plan into the distributed IR without tablet placement. Useful for unit tests and diagnostics.

Trait Implementations

impl Clone for DataFusionDistributedPlanner

fn clone(&self) -> DataFusionDistributedPlanner

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DataFusionDistributedPlanner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.