pub trait Operator: Send + Sync {
// Required methods
fn id(&self) -> FlowNodeId;
fn apply(
&self,
txn: &mut FlowTransaction,
change: FlowChange,
evaluator: &StandardRowEvaluator,
) -> Result<FlowChange>;
fn get_rows(
&self,
txn: &mut FlowTransaction,
rows: &[RowNumber],
) -> Result<Vec<Option<Row>>>;
}