Skip to main content

Operator

reifydb_sub_flow::operator

Trait Operator 

Source 
pub trait Operator: Send + Sync {
    // Required methods
    fn id(&self) -> FlowNodeId;
    fn apply(&self, txn: &mut FlowTransaction, change: Change) -> Result<Change>;
    fn pull(
        &self,
        txn: &mut FlowTransaction,
        rows: &[RowNumber],
    ) -> Result<Columns>;
}

Required Methods§

Source

fn id(&self) -> FlowNodeId

Source

fn apply(&self, txn: &mut FlowTransaction, change: Change) -> Result<Change>

Source

fn pull(&self, txn: &mut FlowTransaction, rows: &[RowNumber]) -> Result<Columns>

Implementors§