Skip to main content

Operator

Trait Operator 

Source
pub trait Operator: Send + Sync {
    // Required methods
    fn next(&mut self) -> OperatorResult;
    fn reset(&mut self);
    fn name(&self) -> &'static str;
}
Expand description

The core trait for pull-based operators.

Call next() repeatedly until it returns None. Each call returns a batch of rows (a DataChunk) or an error.

Required Methods§

Source

fn next(&mut self) -> OperatorResult

Pulls the next batch of data. Returns None when exhausted.

Source

fn reset(&mut self)

Resets to initial state so you can iterate again.

Source

fn name(&self) -> &'static str

Returns a name for debugging/explain output.

Implementors§

Source§

impl Operator for CardinalityTrackingWrapper

Source§

impl Operator for EmptyOperator

Source§

impl Operator for NodeListOperator

Source§

impl Operator for SingleRowOperator

Source§

impl Operator for AddLabelOperator

Source§

impl Operator for ApplyOperator

Source§

impl Operator for CreateEdgeOperator

Source§

impl Operator for CreateNodeOperator

Source§

impl Operator for DeleteEdgeOperator

Source§

impl Operator for DeleteNodeOperator

Source§

impl Operator for DistinctOperator

Source§

impl Operator for ExceptOperator

Source§

impl Operator for ExpandOperator

Source§

impl Operator for FactorizedAggregateOperator

Source§

impl Operator for FactorizedExpandOperator

Source§

impl Operator for FilterOperator

Source§

impl Operator for HashAggregateOperator

Source§

impl Operator for HashJoinOperator

Source§

impl Operator for HorizontalAggregateOperator

Source§

impl Operator for IntersectOperator

Source§

impl Operator for LazyFactorizedChainOperator

Source§

impl Operator for LeapfrogJoinOperator

Source§

impl Operator for LimitOperator

Source§

impl Operator for LimitSkipOperator

Source§

impl Operator for MapCollectOperator

Source§

impl Operator for MergeOperator

Source§

impl Operator for MergeRelationshipOperator

Source§

impl Operator for NestedLoopJoinOperator

Source§

impl Operator for OtherwiseOperator

Source§

impl Operator for ParameterScanOperator

Source§

impl Operator for ProjectOperator

Source§

impl Operator for RemoveLabelOperator

Source§

impl Operator for ScanOperator

Source§

impl Operator for SetPropertyOperator

Source§

impl Operator for ShortestPathOperator

Source§

impl Operator for SimpleAggregateOperator

Source§

impl Operator for SkipOperator

Source§

impl Operator for SortOperator

Source§

impl Operator for UnionOperator

Source§

impl Operator for UnwindOperator

Source§

impl Operator for VariableLengthExpandOperator

Source§

impl Operator for VectorJoinOperator

Source§

impl Operator for VectorScanOperator