Struct FFIOperator 

pub struct FFIOperator { /* private fields */ }

FFI operator that wraps an external operator implementation

Implementations

impl FFIOperator

pub fn new( descriptor: OperatorDescriptorFFI, instance: *mut c_void, operator_id: FlowNodeId, executor: Executor, ) -> Self

Create a new FFI operator

Trait Implementations

impl Drop for FFIOperator

fn drop(&mut self)

Executes the destructor for this type.

impl Operator for FFIOperator

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.

impl Send for FFIOperator

impl Sync for FFIOperator