Struct RowNumberProvider 

pub struct RowNumberProvider { /* private fields */ }

Provides stable encoded numbers for keys with automatic Insert/Update detection

This component maintains:

• A sequential counter for generating new encoded numbers
• A mapping from keys to their assigned encoded numbers

When a key is seen for the first time, it gets a new encoded number and returns true. When a key is seen again, it returns the existing encoded number and false.

Implementations

impl RowNumberProvider

pub fn new(node: FlowNodeId) -> Self

Create a new RowNumberProvider for the given operator

pub fn get_or_create_row_number<O: RawStatefulOperator>( &self, txn: &mut FlowTransaction, operator: &O, key: &EncodedKey, ) -> Result<(RowNumber, bool)>

Get or create a RowNumber for a given key Returns (RowNumber, is_new) where is_new indicates if it was newly created

pub fn remove_by_prefix<O: RawStatefulOperator>( &self, txn: &mut FlowTransaction, operator: &O, key_prefix: &[u8], ) -> Result<()>

Remove all encoded number mappings with the given prefix This is useful for cleaning up all join results from a specific left encoded