Trait BatchPlanNode

pub trait BatchPlanNode:
    PlanNodeCommon<Batch>
    + ToDistributedBatch
    + ToLocalBatch
    + TryToBatchPb { }

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 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 BatchPlanNodeCopy item path

Implementations§

impl dyn BatchPlanNode

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

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

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

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

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

impl dyn BatchPlanNode

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

pub fn explain_myself_to_string(&self) -> String

impl dyn BatchPlanNode

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

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

impl dyn BatchPlanNode

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>

pub fn as_batch_group_top_n(&self) -> Option<&BatchGroupTopN>

pub fn as_batch_source(&self) -> Option<&BatchSource>

pub fn as_batch_over_window(&self) -> Option<&BatchOverWindow>

pub fn as_batch_max_one_row(&self) -> Option<&BatchMaxOneRow>

pub fn as_batch_kafka_scan(&self) -> Option<&BatchKafkaScan>

pub fn as_batch_iceberg_scan(&self) -> Option<&BatchIcebergScan>

pub fn as_batch_file_scan(&self) -> Option<&BatchFileScan>

pub fn as_batch_postgres_query(&self) -> Option<&BatchPostgresQuery>

pub fn as_batch_my_sql_query(&self) -> Option<&BatchMySqlQuery>

pub fn as_batch_vector_search(&self) -> Option<&BatchVectorSearch>

Trait Implementations§

impl Hash for dyn BatchPlanNode

fn hash<H: Hasher>(&self, state: &mut H)

impl PartialEq for dyn BatchPlanNode

fn eq(&self, other: &Self) -> bool

const fn ne(&self, other: &Rhs) -> bool

impl Eq for dyn BatchPlanNode

Implementors§

impl BatchPlanNode for BatchDelete

impl BatchPlanNode for BatchExchange

impl BatchPlanNode for BatchExpand

impl BatchPlanNode for BatchFileScan

impl BatchPlanNode for BatchFilter

impl BatchPlanNode for BatchGroupTopN

impl BatchPlanNode for BatchHashAgg

impl BatchPlanNode for BatchHashJoin

impl BatchPlanNode for BatchHopWindow

impl BatchPlanNode for BatchIcebergScan

impl BatchPlanNode for BatchInsert

impl BatchPlanNode for BatchKafkaScan

impl BatchPlanNode for BatchLimit

impl BatchPlanNode for BatchLogSeqScan

impl BatchPlanNode for BatchLookupJoin

impl BatchPlanNode for BatchMaxOneRow

impl BatchPlanNode for BatchMySqlQuery

impl BatchPlanNode for BatchNestedLoopJoin

impl BatchPlanNode for BatchOverWindow

Trait BatchPlanNode

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

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

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

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