Trait PlanNode

pub trait PlanNode:
    PlanTreeNode
    + DynClone
    + DynEq
    + DynHash
    + Distill
    + Debug
    + Downcast
    + ColPrunable
    + ExprRewritable
    + ExprVisitable
    + ToBatch
    + ToStream
    + ToDistributedBatch
    + ToPb
    + ToLocalBatch
    + PredicatePushdown
    + AnyPlanNodeMeta { }

Expand description

The common trait over all plan nodes. Used by optimizer framework which will treat all node as dyn PlanNode

We split the trait into lots of sub-trait so that we can easily use macro to impl them.

Implementations§

Returns true if the trait object wraps an object of type __T.

Returns a boxed object from a boxed trait object if the underlying object is of type __T. Returns the original boxed trait if it isn’t.

Returns an Rc-ed object from an Rc-ed trait object if the underlying object is of type __T. Returns the original Rc-ed trait if it isn’t.

Returns a reference to the object within the trait object if it is of type __T, or None if it isn’t.

Returns a mutable reference to the object within the trait object if it is of type __T, or None if it isn’t.

Directly implement methods for PlanNode to access the fields defined in GenericPlanRef.

Serialize the plan node and its children to a stream plan proto.

Note that some operators has their own implementation of to_stream_prost. We have a hook inside to do some ad-hoc things.

Serialize the plan node and its children to a batch plan proto.

Serialize the plan node and its children to a batch plan proto without the identity field (for testing).

Trait Implementations§

Feeds this value into the given Hasher. Read more

Tests for self and other values to be equal, and is used by ==.

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

Implementors§

Trait PlanNodeCopy item path

Implementations§

impl dyn PlanNode

pub fn is<__T: PlanNode>(&self) -> bool

pub fn downcast<__T: PlanNode>(self: Box<Self>) -> Result<Box<__T>, Box<Self>>

pub fn downcast_rc<__T: PlanNode>(self: Rc<Self>) -> Result<Rc<__T>, Rc<Self>>

pub fn downcast_ref<__T: PlanNode>(&self) -> Option<&__T>

pub fn downcast_mut<__T: PlanNode>(&mut self) -> Option<&mut __T>

impl dyn PlanNode

pub fn id(&self) -> PlanNodeId

pub fn ctx(&self) -> OptimizerContextRef

pub fn schema(&self) -> &Schema

pub fn stream_key(&self) -> Option<&[usize]>

pub fn functional_dependency(&self) -> &FunctionalDependencySet

impl dyn PlanNode

pub fn to_stream_prost( &self, state: &mut BuildFragmentGraphState, ) -> Result<PbStreamPlan, SchedulerError>

pub fn to_batch_prost(&self) -> Result<PbBatchPlan, SchedulerError>

pub fn to_batch_prost_identity( &self, identity: bool, ) -> Result<PbBatchPlan, SchedulerError>

pub fn explain_myself_to_string(&self) -> String

impl dyn PlanNode

pub fn as_logical_agg(&self) -> Option<&LogicalAgg>

pub fn as_logical_apply(&self) -> Option<&LogicalApply>

pub fn as_logical_filter(&self) -> Option<&LogicalFilter>

pub fn as_logical_project(&self) -> Option<&LogicalProject>

pub fn as_logical_scan(&self) -> Option<&LogicalScan>

pub fn as_logical_cdc_scan(&self) -> Option<&LogicalCdcScan>

pub fn as_logical_sys_scan(&self) -> Option<&LogicalSysScan>

pub fn as_logical_source(&self) -> Option<&LogicalSource>

pub fn as_logical_insert(&self) -> Option<&LogicalInsert>

pub fn as_logical_delete(&self) -> Option<&LogicalDelete>

pub fn as_logical_update(&self) -> Option<&LogicalUpdate>

pub fn as_logical_join(&self) -> Option<&LogicalJoin>

pub fn as_logical_values(&self) -> Option<&LogicalValues>

pub fn as_logical_limit(&self) -> Option<&LogicalLimit>

pub fn as_logical_top_n(&self) -> Option<&LogicalTopN>

pub fn as_logical_hop_window(&self) -> Option<&LogicalHopWindow>

pub fn as_logical_table_function(&self) -> Option<&LogicalTableFunction>

pub fn as_logical_multi_join(&self) -> Option<&LogicalMultiJoin>

pub fn as_logical_expand(&self) -> Option<&LogicalExpand>

pub fn as_logical_project_set(&self) -> Option<&LogicalProjectSet>

pub fn as_logical_union(&self) -> Option<&LogicalUnion>

pub fn as_logical_over_window(&self) -> Option<&LogicalOverWindow>

pub fn as_logical_share(&self) -> Option<&LogicalShare>

pub fn as_logical_now(&self) -> Option<&LogicalNow>

pub fn as_logical_dedup(&self) -> Option<&LogicalDedup>

pub fn as_logical_intersect(&self) -> Option<&LogicalIntersect>

pub fn as_logical_except(&self) -> Option<&LogicalExcept>

pub fn as_logical_max_one_row(&self) -> Option<&LogicalMaxOneRow>

pub fn as_logical_kafka_scan(&self) -> Option<&LogicalKafkaScan>

pub fn as_logical_iceberg_scan(&self) -> Option<&LogicalIcebergScan>

pub fn as_logical_recursive_union(&self) -> Option<&LogicalRecursiveUnion>

pub fn as_logical_cte_ref(&self) -> Option<&LogicalCteRef>

pub fn as_logical_change_log(&self) -> Option<&LogicalChangeLog>

pub fn as_logical_file_scan(&self) -> Option<&LogicalFileScan>

pub fn as_logical_postgres_query(&self) -> Option<&LogicalPostgresQuery>

pub fn as_logical_my_sql_query(&self) -> Option<&LogicalMySqlQuery>

pub fn as_batch_simple_agg(&self) -> Option<&BatchSimpleAgg>

pub fn as_batch_hash_agg(&self) -> Option<&BatchHashAgg>

pub fn as_batch_sort_agg(&self) -> Option<&BatchSortAgg>

pub fn as_batch_project(&self) -> Option<&BatchProject>

pub fn as_batch_filter(&self) -> Option<&BatchFilter>

pub fn as_batch_insert(&self) -> Option<&BatchInsert>

pub fn as_batch_delete(&self) -> Option<&BatchDelete>

pub fn as_batch_update(&self) -> Option<&BatchUpdate>

pub fn as_batch_seq_scan(&self) -> Option<&BatchSeqScan>

pub fn as_batch_sys_seq_scan(&self) -> Option<&BatchSysSeqScan>

pub fn as_batch_log_seq_scan(&self) -> Option<&BatchLogSeqScan>

pub fn as_batch_hash_join(&self) -> Option<&BatchHashJoin>

pub fn as_batch_nested_loop_join(&self) -> Option<&BatchNestedLoopJoin>

pub fn as_batch_values(&self) -> Option<&BatchValues>

pub fn as_batch_sort(&self) -> Option<&BatchSort>

pub fn as_batch_exchange(&self) -> Option<&BatchExchange>

pub fn as_batch_limit(&self) -> Option<&BatchLimit>

pub fn as_batch_top_n(&self) -> Option<&BatchTopN>

pub fn as_batch_hop_window(&self) -> Option<&BatchHopWindow>

pub fn as_batch_table_function(&self) -> Option<&BatchTableFunction>

pub fn as_batch_expand(&self) -> Option<&BatchExpand>

pub fn as_batch_lookup_join(&self) -> Option<&BatchLookupJoin>

pub fn as_batch_project_set(&self) -> Option<&BatchProjectSet>

pub fn as_batch_union(&self) -> Option<&BatchUnion>

Trait PlanNode

pub fn downcast<T: PlanNode>(self: Box<Self>) -> Result<Box<T>, Box<Self>>

pub fn downcast_rc<T: PlanNode>(self: Rc<Self>) -> Result<Rc<T>, Rc<Self>>

pub fn downcast_ref<T: PlanNode>(&self) -> Option<&T>

pub fn downcast_mut<T: PlanNode>(&mut self) -> Option<&mut T>