Enum QueryStep 

pub enum QueryStep {
    NodeScan {
        shard_id: ShardId,
        label: Option<String>,
        filter: Option<String>,
    },
    EdgeScan {
        shard_id: ShardId,
        edge_type: Option<String>,
    },
    Join {
        left_shard: ShardId,
        right_shard: ShardId,
        join_key: String,
    },
    Aggregate {
        operation: AggregateOp,
        group_by: Option<String>,
    },
    Filter {
        predicate: String,
    },
    Sort {
        key: String,
        ascending: bool,
    },
    Limit {
        count: usize,
    },
}

Individual step in query execution

Variants

NodeScan

Scan nodes with optional filter

Fields

shard_id: ShardId

label: Option<String>

filter: Option<String>

EdgeScan

Scan edges

Fields

shard_id: ShardId

edge_type: Option<String>

Join

Join results from multiple shards

Fields

left_shard: ShardId

right_shard: ShardId

join_key: String

Aggregate

Aggregate results

Fields

operation: AggregateOp

group_by: Option<String>

Filter

Filter results

Fields

predicate: String

Sort

Sort results

Fields

key: String

ascending: bool

Limit

Limit results

Fields

count: usize

Trait Implementations

impl Clone for QueryStep

fn clone(&self) -> QueryStep

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueryStep

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueryStep

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueryStep

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

where __S: Serializer,

Serialize this value into the given Serde serializer.