risingwave_frontend::optimizer::plan_node

Trait ToLocalBatch

source
pub trait ToLocalBatch {
    // Required method
    fn to_local(&self) -> Result<PlanRef, RwError>;

    // Provided method
    fn to_local_with_order_required(
        &self,
        required_order: &Order,
    ) -> Result<PlanRef, RwError> { ... }
}
Expand description

Converts a batch physical plan to local plan for local execution.

This is quite similar to ToBatch, but different in several ways. For example it converts scan to exchange + scan.

Required Methods§

Provided Methods§

source

fn to_local_with_order_required( &self, required_order: &Order, ) -> Result<PlanRef, RwError>

Convert the plan to batch local physical plan and satisfy the required Order

Implementors§

source§

impl ToLocalBatch for BatchDelete

source§

impl ToLocalBatch for BatchExchange

source§

impl ToLocalBatch for BatchExpand

source§

impl ToLocalBatch for BatchFileScan

source§

impl ToLocalBatch for BatchFilter

source§

impl ToLocalBatch for BatchGroupTopN

source§

impl ToLocalBatch for BatchHashAgg

source§

impl ToLocalBatch for BatchHashJoin

source§

impl ToLocalBatch for BatchHopWindow

source§

impl ToLocalBatch for BatchIcebergScan

source§

impl ToLocalBatch for BatchInsert

source§

impl ToLocalBatch for BatchKafkaScan

source§

impl ToLocalBatch for BatchLimit

source§

impl ToLocalBatch for BatchLogSeqScan

source§

impl ToLocalBatch for BatchLookupJoin

source§

impl ToLocalBatch for BatchMaxOneRow

source§

impl ToLocalBatch for BatchMySqlQuery

source§

impl ToLocalBatch for BatchNestedLoopJoin

source§

impl ToLocalBatch for BatchOverWindow

source§

impl ToLocalBatch for BatchPostgresQuery

source§

impl ToLocalBatch for BatchProject

source§

impl ToLocalBatch for BatchProjectSet

source§

impl ToLocalBatch for BatchSeqScan

source§

impl ToLocalBatch for BatchSimpleAgg

source§

impl ToLocalBatch for BatchSort

source§

impl ToLocalBatch for BatchSortAgg

source§

impl ToLocalBatch for BatchSource

source§

impl ToLocalBatch for BatchSysSeqScan

source§

impl ToLocalBatch for BatchTableFunction

source§

impl ToLocalBatch for BatchTopN

source§

impl ToLocalBatch for BatchUnion

source§

impl ToLocalBatch for BatchUpdate

source§

impl ToLocalBatch for BatchValues

source§

impl ToLocalBatch for LogicalAgg

source§

impl ToLocalBatch for LogicalApply

source§

impl ToLocalBatch for LogicalCdcScan

source§

impl ToLocalBatch for LogicalChangeLog

source§

impl ToLocalBatch for LogicalCteRef

source§

impl ToLocalBatch for LogicalDedup

source§

impl ToLocalBatch for LogicalDelete

source§

impl ToLocalBatch for LogicalExcept

source§

impl ToLocalBatch for LogicalExpand

source§

impl ToLocalBatch for LogicalFileScan

source§

impl ToLocalBatch for LogicalFilter

source§

impl ToLocalBatch for LogicalHopWindow

source§

impl ToLocalBatch for LogicalIcebergScan

source§

impl ToLocalBatch for LogicalInsert

source§

impl ToLocalBatch for LogicalIntersect

source§

impl ToLocalBatch for LogicalJoin

source§

impl ToLocalBatch for LogicalKafkaScan

source§

impl ToLocalBatch for LogicalLimit

source§

impl ToLocalBatch for LogicalMaxOneRow

source§

impl ToLocalBatch for LogicalMultiJoin

source§

impl ToLocalBatch for LogicalMySqlQuery

source§

impl ToLocalBatch for LogicalNow

source§

impl ToLocalBatch for LogicalOverWindow

source§

impl ToLocalBatch for LogicalPostgresQuery

source§

impl ToLocalBatch for LogicalProject

source§

impl ToLocalBatch for LogicalProjectSet

source§

impl ToLocalBatch for LogicalRecursiveUnion

source§

impl ToLocalBatch for LogicalScan

source§

impl ToLocalBatch for LogicalShare

source§

impl ToLocalBatch for LogicalSource

source§

impl ToLocalBatch for LogicalSysScan

source§

impl ToLocalBatch for LogicalTableFunction

source§

impl ToLocalBatch for LogicalTopN

source§

impl ToLocalBatch for LogicalUnion

source§

impl ToLocalBatch for LogicalUpdate

source§

impl ToLocalBatch for LogicalValues

source§

impl ToLocalBatch for StreamAsOfJoin

source§

impl ToLocalBatch for StreamCdcTableScan

source§

impl ToLocalBatch for StreamChangeLog

source§

impl ToLocalBatch for StreamDedup

source§

impl ToLocalBatch for StreamDeltaJoin

source§

impl ToLocalBatch for StreamDml

source§

impl ToLocalBatch for StreamDynamicFilter

source§

impl ToLocalBatch for StreamEowcOverWindow

source§

impl ToLocalBatch for StreamExchange

source§

impl ToLocalBatch for StreamExpand

source§

impl ToLocalBatch for StreamFilter

source§

impl ToLocalBatch for StreamFsFetch

source§

impl ToLocalBatch for StreamGlobalApproxPercentile

source§

impl ToLocalBatch for StreamGroupTopN

source§

impl ToLocalBatch for StreamHashAgg

source§

impl ToLocalBatch for StreamHashJoin

source§

impl ToLocalBatch for StreamHopWindow

source§

impl ToLocalBatch for StreamLocalApproxPercentile

source§

impl ToLocalBatch for StreamMaterialize

source§

impl ToLocalBatch for StreamNow

source§

impl ToLocalBatch for StreamOverWindow

source§

impl ToLocalBatch for StreamProject

source§

impl ToLocalBatch for StreamProjectSet

source§

impl ToLocalBatch for StreamRowIdGen

source§

impl ToLocalBatch for StreamRowMerge

source§

impl ToLocalBatch for StreamShare

source§

impl ToLocalBatch for StreamSimpleAgg

source§

impl ToLocalBatch for StreamSink

source§

impl ToLocalBatch for StreamEowcSort

source§

impl ToLocalBatch for StreamSource

source§

impl ToLocalBatch for StreamSourceScan

source§

impl ToLocalBatch for StreamStatelessSimpleAgg

source§

impl ToLocalBatch for StreamTableScan

source§

impl ToLocalBatch for StreamTemporalJoin

source§

impl ToLocalBatch for StreamTopN

source§

impl ToLocalBatch for StreamUnion

source§

impl ToLocalBatch for StreamValues

source§

impl ToLocalBatch for StreamWatermarkFilter