Struct NativeOperatorContext 

pub struct NativeOperatorContext<'a> { /* private fields */ }

Implementations

impl<'a> NativeOperatorContext<'a>

pub fn new(bridge: &'a mut (dyn NativeBridge + 'a), node: FlowNodeId) -> Self

pub fn take_diffs(&mut self) -> Vec<Diff>

Trait Implementations

impl OperatorContext for NativeOperatorContext<'_>

type InsertEmit<'a> = NativeRowEmit<'a> where Self: 'a

type UpdateEmit<'a> = NativeUpdateEmit<'a> where Self: 'a

type RemoveEmit<'a> = NativeRowEmit<'a> where Self: 'a

fn operator_id(&self) -> FlowNodeId

fn clock_now_nanos(&self) -> u64

fn state(&mut self) -> impl StateApi + '_

fn internal_state(&mut self) -> impl InternalStateApi + '_

fn store(&mut self) -> impl StoreApi + '_

fn catalog(&mut self) -> impl CatalogApi + '_

fn dictionary(&mut self) -> impl DictionaryApi + '_

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

fn get_or_create_row_numbers( &mut self, keys: &[EncodedKey], ) -> SdkResult<Vec<(RowNumber, bool)>>

fn allocate_row_numbers(&mut self, count: u64) -> SdkResult<RowNumber>

Reserve count fresh, globally-unique output row numbers for this operator and return the start of the [start, start + count) range. Backed by the host’s process-shared in-memory allocator so it is immune to the committing transaction’s MVCC snapshot (unlike a counter read from the store).

fn shape_for_row(&mut self, row: &EncodedRow) -> SdkResult<RowShape>

fn insert_emit<R: Row>( &mut self, _row_capacity: usize, ) -> SdkResult<NativeRowEmit<'_>>

fn update_emit<R: Row>( &mut self, _row_capacity: usize, ) -> SdkResult<NativeUpdateEmit<'_>>

fn remove_emit<R: Row>( &mut self, _row_capacity: usize, ) -> SdkResult<NativeRowEmit<'_>>

fn emit_insert<R>( &mut self, rows: &[R], row_numbers: &[RowNumber], ) -> Result<(), SdkError>

where R: Row,

fn emit_update<R>( &mut self, pre: &[R], post: &[R], row_numbers: &[RowNumber], ) -> Result<(), SdkError>

where R: Row,

fn emit_remove<R>( &mut self, rows: &[R], row_numbers: &[RowNumber], ) -> Result<(), SdkError>

where R: Row,