Struct LineageExtensionPlanner 

pub struct LineageExtensionPlanner;

Lowers a LineageMarker into an OpenLineageExec at physical-planning time. Register it on the session’s physical planner (see crate::session::instrument_session_state).

Trait Implementations

impl Debug for LineageExtensionPlanner

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

Formats the value using the given formatter.

impl Default for LineageExtensionPlanner

fn default() -> LineageExtensionPlanner

Returns the “default value” for a type.

impl ExtensionPlanner for LineageExtensionPlanner

fn plan_extension<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'async_trait>( &'life0 self, _planner: &'life1 dyn PhysicalPlanner, node: &'life2 dyn UserDefinedLogicalNode, _logical_inputs: &'life3 [&'life4 LogicalPlan], physical_inputs: &'life5 [Arc<dyn ExecutionPlan>], _session_state: &'life6 SessionState, ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ExecutionPlan>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait,

Create a physical plan for a UserDefinedLogicalNode.

fn plan_table_scan<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _planner: &'life1 dyn PhysicalPlanner, _scan: &'life2 TableScan, _session_state: &'life3 SessionState, ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ExecutionPlan>>, DataFusionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, Self: Sync + 'async_trait,

Create a physical plan for a LogicalPlan::TableScan.