Struct OpenLineageQueryPlanner 

pub struct OpenLineageQueryPlanner { /* private fields */ }

A QueryPlanner that emits OpenLineage events around a query.

It does the &SessionState-bound, async work — extract lineage, resolve context, emit START, mint the run_id, emit FAIL on a planning error — then hands off to physical planning by wrapping the logical plan in a LineageMarker. The registered LineageExtensionPlanner lowers that marker into the terminal OpenLineageExec. Built by crate::session::instrument_session_state.

Implementations

impl OpenLineageQueryPlanner

pub fn new( client: OpenLineageClient, context: Arc<dyn LineageContextProvider>, config: OpenLineageConfig, extra_extension_planners: Vec<Arc<dyn ExtensionPlanner + Send + Sync>>, ) -> Self

Build a planner whose physical planning lowers our marker plus extra_extension_planners (any the host session already registered).

Trait Implementations

impl Debug for OpenLineageQueryPlanner

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

Formats the value using the given formatter.

impl QueryPlanner for OpenLineageQueryPlanner

fn create_physical_plan<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, logical_plan: &'life1 LogicalPlan, session_state: &'life2 SessionState, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Given a LogicalPlan, create an ExecutionPlan suitable for execution