Struct OperatorNode 

pub struct OperatorNode {
    pub id: usize,
    pub op_type: OperatorType,
    pub estimated_rows: f64,
    pub estimated_cost: f64,
    pub actual_rows: Option<f64>,
    pub actual_time_ms: Option<f64>,
    pub embedding: Option<Vec<f32>>,
}

A node in the query DAG

Fields

id: usize

op_type: OperatorType

estimated_rows: f64

estimated_cost: f64

actual_rows: Option<f64>

actual_time_ms: Option<f64>

embedding: Option<Vec<f32>>

Implementations

impl OperatorNode

pub fn new(id: usize, op_type: OperatorType) -> Self

Create a new operator node

pub fn seq_scan(id: usize, table: &str) -> Self

Create a sequential scan node

pub fn index_scan(id: usize, index: &str, table: &str) -> Self

Create an index scan node

pub fn hnsw_scan(id: usize, index: &str, ef_search: u32) -> Self

Create an HNSW scan node

pub fn ivf_flat_scan(id: usize, index: &str, nprobe: u32) -> Self

Create an IVF-Flat scan node

pub fn nested_loop_join(id: usize) -> Self

Create a nested loop join node

pub fn hash_join(id: usize, key: &str) -> Self

Create a hash join node

pub fn merge_join(id: usize, key: &str) -> Self

Create a merge join node

pub fn filter(id: usize, predicate: &str) -> Self

Create a filter node

pub fn project(id: usize, columns: Vec<String>) -> Self

Create a project node

pub fn sort(id: usize, keys: Vec<String>) -> Self

Create a sort node

pub fn sort_with_order( id: usize, keys: Vec<String>, descending: Vec<bool>, ) -> Self

Create a sort node with descending flags

pub fn limit(id: usize, count: usize) -> Self

Create a limit node

pub fn aggregate(id: usize, functions: Vec<String>) -> Self

Create an aggregate node

pub fn group_by(id: usize, keys: Vec<String>) -> Self

Create a group by node

pub fn vector_distance(id: usize, metric: &str) -> Self

Create a vector distance node

pub fn rerank(id: usize, model: &str) -> Self

Create a rerank node

pub fn materialize(id: usize) -> Self

Create a materialize node

pub fn result(id: usize) -> Self

Create a result node

pub fn with_estimates(self, rows: f64, cost: f64) -> Self

Set estimated statistics

pub fn with_actuals(self, rows: f64, time_ms: f64) -> Self

Set actual statistics

pub fn with_embedding(self, embedding: Vec<f32>) -> Self

Set embedding vector

Trait Implementations

impl Clone for OperatorNode

fn clone(&self) -> OperatorNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperatorNode

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OperatorNode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OperatorNode

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.