Struct HummockVersionDeltaCommon

pub struct HummockVersionDeltaCommon<T> {
    pub id: HummockVersionId,
    pub prev_id: HummockVersionId,
    pub group_deltas: HashMap<CompactionGroupId, GroupDeltasCommon<T>>,
    pub(crate) max_committed_epoch: u64,
    pub trivial_move: bool,
    pub new_table_watermarks: HashMap<TableId, TableWatermarks>,
    pub removed_table_ids: HashSet<TableId>,
    pub change_log_delta: HashMap<TableId, ChangeLogDeltaCommon<T>>,
    pub state_table_info_delta: HashMap<TableId, StateTableInfoDelta>,
}

Fields

id: HummockVersionId

prev_id: HummockVersionId

group_deltas: HashMap<CompactionGroupId, GroupDeltasCommon<T>>

max_committed_epoch: u64

👎Deprecated

trivial_move: bool

new_table_watermarks: HashMap<TableId, TableWatermarks>

removed_table_ids: HashSet<TableId>

change_log_delta: HashMap<TableId, ChangeLogDeltaCommon<T>>

state_table_info_delta: HashMap<TableId, StateTableInfoDelta>

Implementations

impl<T> HummockVersionDeltaCommon<T>

where T: for<'a> From<&'a PbSstableInfo>, PbSstableInfo: for<'a> From<&'a T>,

pub fn from_persisted_protobuf(delta: &PbHummockVersionDelta) -> Self

Convert the PbHummockVersionDelta deserialized from persisted state to HummockVersionDelta. We should maintain backward compatibility.

pub fn from_rpc_protobuf(delta: &PbHummockVersionDelta) -> Self

Convert the PbHummockVersionDelta received from rpc to HummockVersionDelta. No need to maintain backward compatibility.

pub fn to_protobuf(&self) -> PbHummockVersionDelta

impl<T> HummockVersionDeltaCommon<T>

where T: SstableIdReader + ObjectIdReader,

pub fn newly_added_object_ids(&self) -> HashSet<HummockSstableObjectId>

Get the newly added object ids from the version delta.

Note: the result can be false positive because we only collect the set of sst object ids in the inserted_table_infos, but it is possible that the object is moved or split from other compaction groups or levels.

pub fn newly_added_sst_ids(&self) -> HashSet<HummockSstableObjectId>

pub fn newly_added_sst_infos<'a>( &'a self, select_group: Option<&'a HashSet<CompactionGroupId>>, ) -> impl Iterator<Item = &'a T> + 'a

impl HummockVersionDeltaCommon<SstableInfo>

pub fn max_committed_epoch_for_migration(&self) -> HummockEpoch

Trait Implementations

impl<T: Clone> Clone for HummockVersionDeltaCommon<T>

fn clone(&self) -> HummockVersionDeltaCommon<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for HummockVersionDeltaCommon<T>

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

Formats the value using the given formatter.

impl<T> From<&HummockVersionDelta> for HummockVersionDeltaCommon<T>

where T: for<'a> From<&'a PbSstableInfo>,

fn from(pb_version_delta: &PbHummockVersionDelta) -> Self

Converts to this type from the input type.

impl<T> From<&HummockVersionDeltaCommon<T>> for PbHummockVersionDelta

where PbSstableInfo: for<'a> From<&'a T>,

fn from(version_delta: &HummockVersionDeltaCommon<T>) -> Self

Converts to this type from the input type.

impl<T> From<HummockVersionDelta> for HummockVersionDeltaCommon<T>

where T: From<PbSstableInfo>,

fn from(pb_version_delta: PbHummockVersionDelta) -> Self

Converts to this type from the input type.

impl<T> From<HummockVersionDeltaCommon<T>> for PbHummockVersionDelta

where PbSstableInfo: From<T>,

fn from(version_delta: HummockVersionDeltaCommon<T>) -> Self

Converts to this type from the input type.

impl<T: PartialEq> PartialEq for HummockVersionDeltaCommon<T>

fn eq(&self, other: &HummockVersionDeltaCommon<T>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T> StructuralPartialEq for HummockVersionDeltaCommon<T>