Struct OperatorContext 

pub struct OperatorContext { /* private fields */ }

Operator context providing access to state and other resources

Implementations

impl OperatorContext

pub fn new(ctx: *mut FFIContext) -> Self

Create a new operator context from an FFI context pointer

Safety

The caller must ensure ctx is non-null and valid for the lifetime of this context

pub fn operator_id(&self) -> FlowNodeId

Get the operator ID from the FFI context

pub fn state(&mut self) -> State<'_>

Get a state manager

pub fn store(&mut self) -> Store<'_>

Get read-only access to the underlying store

pub fn catalog(&mut self) -> Catalog<'_>

Get read-only access to the catalog

pub fn get_or_create_row_number( &mut self, key: &EncodedKey, ) -> Result<(RowNumber, bool)>

Get or create a row number for a given key

This is a convenience method that creates a RowNumberProvider and delegates to its get_or_create_row_number method.

Returns (RowNumber, is_new) where is_new indicates if this is a newly created row number.