Struct tidb_query_executors::index_scan_executor::IndexScanExecutorImpl

struct IndexScanExecutorImpl {
    context: EvalContext,
    schema: Vec<FieldType>,
    columns_id_without_handle: Vec<i64>,
    columns_id_for_common_handle: Vec<i64>,
    decode_handle_strategy: DecodeHandleStrategy,
    pid_column_cnt: usize,
    index_version: i64,
}

Fields

context: EvalContext

See TableScanExecutorImpl’s context.

schema: Vec<FieldType>

See TableScanExecutorImpl’s schema.

columns_id_without_handle: Vec<i64>

ID of interested columns (exclude PK handle column).

columns_id_for_common_handle: Vec<i64>

decode_handle_strategy: DecodeHandleStrategy

The strategy to decode handles. Handle will be always placed in the last column.

pid_column_cnt: usize

Number of partition ID columns, now it can only be 0 or 1.

index_version: i64

Implementations

impl IndexScanExecutorImpl

fn decode_int_handle_from_value(&self, value: &[u8]) -> Result<i64>

fn decode_int_handle_from_key(&self, key: &[u8]) -> Result<i64>

fn extract_columns_from_row_format(
    &mut self,
    value: &[u8],
    columns: &mut LazyBatchColumnVec
) -> Result<()>

fn extract_columns_from_datum_format(
    datum: &mut &[u8],
    columns: &mut [LazyBatchColumn]
) -> Result<()>

fn process_old_collation_kv(
    &mut self,
    key_payload: &[u8],
    value: &[u8],
    columns: &mut LazyBatchColumnVec
) -> Result<()>

fn restore_original_data<'a>(
    &self,
    restored_values: &[u8],
    column_iter: impl Iterator<Item = (&'a FieldType, &'a i64, &'a mut LazyBatchColumn)>
) -> Result<()>

fn get_index_version(value: &[u8]) -> Result<i64>

fn process_kv_general(
    &mut self,
    key_payload: &[u8],
    value: &[u8],
    columns: &mut LazyBatchColumnVec
) -> Result<()>

fn build_operations<'a, 'b>(
    &'b self,
    key_payload: &'a [u8],
    index_value: &'a [u8]
) -> Result<(DecodeHandleOp<'a>, DecodePartitionIdOp<'a>, RestoreData<'a>)>

fn decode_index_columns(
    &mut self,
    key_payload: &[u8],
    columns: &mut LazyBatchColumnVec,
    restore_data: RestoreData<'_>
) -> Result<()>

fn decode_handle_columns(
    &mut self,
    decode_handle: DecodeHandleOp<'_>,
    columns: &mut LazyBatchColumnVec,
    restore_data: RestoreData<'_>
) -> Result<()>

fn decode_pid_columns(
    &mut self,
    columns: &mut LazyBatchColumnVec,
    decode_pid: DecodePartitionIdOp<'_>
) -> Result<()>

fn split_common_handle(value: &[u8]) -> Result<(&[u8], &[u8])>

fn split_partition_id(value: &[u8]) -> Result<(&[u8], &[u8])>

fn split_restore_data(value: &[u8]) -> Result<(&[u8], &[u8])>

Trait Implementations

impl ScanExecutorImpl for IndexScanExecutorImpl

fn schema(&self) -> &[FieldType]

Gets the schema.

fn mut_context(&mut self) -> &mut EvalContext

Gets a mutable reference of the executor context.

fn build_column_vec(&self, scan_rows: usize) -> LazyBatchColumnVec

Constructs empty columns, with PK containing int handle in decoded format and the rest in raw format.

Note: the structure of the constructed column is the same as table scan executor but due to different reasons.

fn process_kv_pair(
    &mut self,
    key: &[u8],
    value: &[u8],
    columns: &mut LazyBatchColumnVec
) -> Result<()>

Accepts a key value pair and fills the column vector.