risingwave_frontend::optimizer::plan_node

Trait BatchPlanNode

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

Implementations§

Source§

impl dyn BatchPlanNode

Source

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

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

Source

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

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.

Source

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

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.

Source

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

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

Source

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

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

Source§

impl dyn BatchPlanNode

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

Source

pub fn id(&self) -> PlanNodeId

Source

pub fn ctx(&self) -> OptimizerContextRef

Source

pub fn schema(&self) -> &Schema

Source

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

Source

pub fn functional_dependency(&self) -> &FunctionalDependencySet

Source

pub fn explain_myself_to_string(&self) -> String

Source§

impl dyn BatchPlanNode

Source

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

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

Source

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

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

Source§

impl dyn BatchPlanNode

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Trait Implementations§

Source§

impl Hash for dyn BatchPlanNode

Source§

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

Feeds this value into the given Hasher. Read more
Source§

impl PartialEq for dyn BatchPlanNode

Source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

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

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

impl Eq for dyn BatchPlanNode

Implementors§