Enum PhysicalPlan 

pub enum PhysicalPlan {
    CreateTable(CreateTablePlan),
    AlterTable(AlterTablePlan),
    DropTable(String),
    CreateIndex(CreateIndexPlan),
    DropIndex(DropIndexPlan),
    Insert(InsertPlan),
    Delete(DeletePlan),
    Update(UpdatePlan),
    Scan {
        table: String,
        alias: Option<String>,
        filter: Option<Expr>,
    },
    IndexScan {
        table: String,
        index: String,
        range: ScanRange,
    },
    GraphBfs {
        start_alias: String,
        start_expr: Expr,
        start_candidates: Option<Box<PhysicalPlan>>,
        steps: Vec<GraphStepPlan>,
        filter: Option<Expr>,
    },
    VectorSearch {
        table: String,
        column: String,
        query_expr: Expr,
        k: u64,
        candidates: Option<Box<PhysicalPlan>>,
    },
    HnswSearch {
        table: String,
        column: String,
        query_expr: Expr,
        k: u64,
        candidates: Option<Box<PhysicalPlan>>,
    },
    Filter {
        input: Box<PhysicalPlan>,
        predicate: Expr,
    },
    Project {
        input: Box<PhysicalPlan>,
        columns: Vec<ProjectColumn>,
    },
    Distinct {
        input: Box<PhysicalPlan>,
    },
    Join {
        left: Box<PhysicalPlan>,
        right: Box<PhysicalPlan>,
        condition: Expr,
        join_type: JoinType,
        left_alias: Option<String>,
        right_alias: Option<String>,
    },
    Sort {
        input: Box<PhysicalPlan>,
        keys: Vec<SortKey>,
    },
    Limit {
        input: Box<PhysicalPlan>,
        count: u64,
    },
    MaterializeCte {
        name: String,
        input: Box<PhysicalPlan>,
    },
    CteRef {
        name: String,
    },
    Union {
        inputs: Vec<PhysicalPlan>,
        all: bool,
    },
    Pipeline(Vec<PhysicalPlan>),
    SetMemoryLimit(SetMemoryLimitValue),
    ShowMemoryLimit,
    SetDiskLimit(SetDiskLimitValue),
    ShowDiskLimit,
    SetSyncConflictPolicy(String),
    ShowSyncConflictPolicy,
}

Variants

CreateTable(CreateTablePlan)

AlterTable(AlterTablePlan)

DropTable(String)

CreateIndex(CreateIndexPlan)

DropIndex(DropIndexPlan)

Insert(InsertPlan)

Delete(DeletePlan)

Update(UpdatePlan)

Scan

Fields

table: String

alias: Option<String>

filter: Option<Expr>

IndexScan

Fields

table: String

index: String

range: ScanRange

GraphBfs

Fields

start_alias: String

start_expr: Expr

start_candidates: Option<Box<PhysicalPlan>>

steps: Vec<GraphStepPlan>

filter: Option<Expr>

VectorSearch

Fields

table: String

column: String

query_expr: Expr

k: u64

candidates: Option<Box<PhysicalPlan>>

HnswSearch

Fields

table: String

column: String

query_expr: Expr

k: u64

candidates: Option<Box<PhysicalPlan>>

Filter

Fields

input: Box<PhysicalPlan>

predicate: Expr

Project

Fields

input: Box<PhysicalPlan>

columns: Vec<ProjectColumn>

Distinct

Fields

input: Box<PhysicalPlan>

Join

Fields

left: Box<PhysicalPlan>

right: Box<PhysicalPlan>

condition: Expr

join_type: JoinType

left_alias: Option<String>

right_alias: Option<String>

Sort

Fields

input: Box<PhysicalPlan>

keys: Vec<SortKey>

Limit

Fields

input: Box<PhysicalPlan>

count: u64

MaterializeCte

Fields

name: String

input: Box<PhysicalPlan>

CteRef

Fields

name: String

Union

Fields

inputs: Vec<PhysicalPlan>

all: bool

Pipeline(Vec<PhysicalPlan>)

SetMemoryLimit(SetMemoryLimitValue)

ShowMemoryLimit

SetDiskLimit(SetDiskLimitValue)

ShowDiskLimit

SetSyncConflictPolicy(String)

ShowSyncConflictPolicy

Implementations

impl PhysicalPlan

pub fn explain(&self) -> String

Trait Implementations

impl Clone for PhysicalPlan

fn clone(&self) -> PhysicalPlan

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PhysicalPlan

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.