Trait ToLocalBatch

Source
pub trait ToLocalBatch {
    // Required method
    fn to_local(&self) -> Result<BatchPlanRef>;

    // Provided method
    fn to_local_with_order_required(
        &self,
        required_order: &Order,
    ) -> Result<BatchPlanRef> { ... }
}
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<BatchPlanRef>

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 BatchGetChannelDeltaStats

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 BatchVectorSearch