Struct HummockReadVersion

pub struct HummockReadVersion {
    table_id: TableId,
    instance_id: LocalInstanceId,
    staging: StagingVersion,
    committed: CommittedVersion,
    is_replicated: bool,
    table_watermarks: Option<PkPrefixTableWatermarksIndex>,
    vnodes: Arc<Bitmap>,
}

A container of information required for reading from hummock.

Fields

table_id: TableId

instance_id: LocalInstanceId

staging: StagingVersion

Local version for staging data.

committed: CommittedVersion

Remote version for committed data.

is_replicated: bool

Indicate if this is replicated. If it is, we should ignore it during global state store read, to avoid duplicated results. Otherwise for local state store, it is fine, see we will see the ReadVersion just for that local state store.

table_watermarks: Option<PkPrefixTableWatermarksIndex>

vnodes: Arc<Bitmap>

Implementations

impl HummockReadVersion

pub fn new_with_replication_option( table_id: TableId, instance_id: LocalInstanceId, committed_version: CommittedVersion, is_replicated: bool, vnodes: Arc<Bitmap>, ) -> Self

pub fn new( table_id: TableId, instance_id: LocalInstanceId, committed_version: CommittedVersion, vnodes: Arc<Bitmap>, ) -> Self

pub fn table_id(&self) -> TableId

pub fn add_imm(&mut self, imm: ImmutableMemtable)

pub fn pending_imm_size(&self) -> usize

pub fn start_upload_pending_imms(&mut self) -> Vec<ImmutableMemtable>

pub fn update(&mut self, info: VersionUpdate)

Updates the read version with VersionUpdate. There will be three data types to be processed VersionUpdate::Staging - StagingData::ImmMem -> Insert into memory’s staging_imm - StagingData::Sst -> Update the sst to memory’s staging_sst and remove the corresponding staging_imms according to the batch_id VersionUpdate::CommittedDelta -> Unimplemented yet VersionUpdate::CommittedSnapshot -> Update committed_version , and clean up related staging_sst and staging_imm in memory according to epoch

pub fn staging(&self) -> &StagingVersion

pub fn committed(&self) -> &CommittedVersion

pub fn filter_regress_watermarks(&self, watermarks: &mut Vec<VnodeWatermark>)

We have assumption that the watermark is increasing monotonically. Therefore, here if the upper layer usage has passed an regressed watermark, we should filter out the regressed watermark. Currently the kv log store may write regressed watermark

pub fn latest_watermark(&self, vnode: VirtualNode) -> Option<Bytes>

pub fn is_replicated(&self) -> bool

pub fn update_vnode_bitmap(&mut self, vnodes: Arc<Bitmap>) -> Arc<Bitmap>

pub fn contains(&self, vnode: VirtualNode) -> bool

pub fn vnodes(&self) -> Arc<Bitmap>

Trait Implementations

impl Clone for HummockReadVersion

fn clone(&self) -> HummockReadVersion

Returns a duplicate of the value.

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

Performs copy-assignment from source.