Struct RowConverter

pub(super) struct RowConverter<'a> {
    state_key_to_table_sub_pk_proj: &'a [usize],
    order_key_indices: &'a [usize],
    order_key_data_types: &'a [DataType],
    order_key_order_types: &'a [OrderType],
    input_pk_indices: &'a [usize],
}

A converter that helps convert [StateKey] to state table sub-PK and convert executor input/output row to [StateKey].

Notes

• [StateKey]: Over window range cache key type, containing order key and input pk.
• State table sub-PK: State table PK = PK prefix (partition key) + sub-PK (order key + input pk).
• Input/output row: Input schema is the prefix of output schema.

You can see that the content of [StateKey] is very similar to state table sub-PK. There’s only one difference: the state table PK and sub-PK don’t have duplicated columns, while in [StateKey], order_key and (input)pk may contain duplicated columns.

Fields

state_key_to_table_sub_pk_proj: &'a [usize]

order_key_indices: &'a [usize]

order_key_data_types: &'a [DataType]

order_key_order_types: &'a [OrderType]

input_pk_indices: &'a [usize]

Implementations

impl<'a> RowConverter<'a>

pub(super) fn calc_state_key_to_table_sub_pk_proj( partition_key_indices: &[usize], order_key_indices: &[usize], input_pk_indices: &'a [usize], ) -> Vec<usize>

Calculate the indices needed for projection from [StateKey] to state table sub-PK (used to do prefixed table scanning). Ideally this function should be called only once by each executor instance. The projection indices vec is the selected column indices in [StateKey].order_key.chain(input_pk).

pub(super) fn state_key_to_table_sub_pk( &self, key: &StateKey, ) -> StreamExecutorResult<OwnedRow>

Convert [StateKey] to sub-PK (table PK without partition key) as OwnedRow.

pub(super) fn row_to_state_key( &self, full_row: impl Row + Copy, ) -> StreamExecutorResult<StateKey>

Convert full input/output row to [StateKey].

Trait Implementations

impl<'a> Clone for RowConverter<'a>

fn clone(&self) -> RowConverter<'a>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a> Debug for RowConverter<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Copy for RowConverter<'a>