Struct tikv::storage::mvcc::PointGetter

pub struct PointGetter<S: Snapshot> {
    snapshot: S,
    multi: bool,
    omit_value: bool,
    isolation_level: IsolationLevel,
    ts: TimeStamp,
    bypass_locks: TsSet,
    met_newer_ts_data: NewerTsCheckState,
    statistics: Statistics,
    write_cursor: Cursor<S::Iter>,
    drained: bool,
}

This struct can be used to get the value of user keys. Internally, rollbacks are ignored and smaller version will be tried. If the isolation level is Si, locks will be checked first.

Use PointGetterBuilder to build PointGetter.

Fields

snapshot: S

multi: bool

omit_value: bool

isolation_level: IsolationLevel

ts: TimeStamp

bypass_locks: TsSet

met_newer_ts_data: NewerTsCheckState

statistics: Statistics

write_cursor: Cursor<S::Iter>

drained: bool

Indicating whether or not this structure can serve more requests. It is meaningful only when multi == false, to protect from producing undefined values when trying to get multiple values under multi == false.

Implementations

impl<S: Snapshot> PointGetter<S>

pub fn take_statistics(&mut self) -> Statistics

Take out and reset the statistics collected so far.

pub fn met_newer_ts_data(&self) -> NewerTsCheckState

Whether we met newer ts data. The result is always Unknown if check_has_newer_ts_data is not set.

pub fn get(&mut self, user_key: &Key) -> Result<Option<Value>>

Get the value of a user key.

If multi == false, this function must be called only once. Future calls return nothing.

fn load_and_check_lock(&mut self, user_key: &Key) -> Result<()>

Get a lock of a user key in the lock CF. If lock exists, it will be checked to see whether it conflicts with the given ts.

In common cases we expect to get nothing in lock cf. Using a get_cf instead of seek is fast in such cases due to no need for RocksDB to continue move and skip deleted entries until find a user key.

fn load_data(&mut self, user_key: &Key) -> Result<Option<Value>>

Load the value.

First, a correct version info in the Write CF will be sought. Then, value will be loaded from Default CF if necessary.

fn load_data_from_default_cf(
    &mut self,
    write_start_ts: TimeStamp,
    user_key: &Key
) -> Result<Value>

Load the value from default CF.

We assume that mostly the keys given to batch get keys are not very close to each other. near_seek will likely fall back to seek in such scenario, which takes 2x time compared to get_cf. Thus we use get_cf directly here.