Struct TestOperator 

pub struct TestOperator {
    pub id: FlowNodeId,
    pub layout: RowShape,
    pub key_types: Vec<Type>,
}

Test operator implementation for stateful traits

Fields

id: FlowNodeId

layout: RowShape

key_types: Vec<Type>

Implementations

impl TestOperator

pub fn new(id: FlowNodeId) -> Self

Create a new test operator with a complex shape

pub fn simple(id: FlowNodeId) -> Self

Create a simple test operator with a single column

pub fn with_key_types(id: FlowNodeId, key_types: Vec<Type>) -> Self

Create a test operator with custom key types

Trait Implementations

impl Operator for TestOperator

fn id(&self) -> FlowNodeId

fn apply(&self, _txn: &mut FlowTransaction, _change: Change) -> Result<Change>

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

fn tick( &self, _txn: &mut FlowTransaction, _timestamp: DateTime, ) -> Result<Option<Change>>

Periodic tick for time-based maintenance (e.g., window eviction). Returns Some(Change) with diffs if maintenance produced changes.