Struct HummockVersionCommon

pub struct HummockVersionCommon<T, L = T> {
    pub id: HummockVersionId,
    pub levels: HashMap<CompactionGroupId, LevelsCommon<T>>,
    pub(crate) max_committed_epoch: u64,
    pub table_watermarks: HashMap<TableId, Arc<TableWatermarks>>,
    pub table_change_log: HashMap<TableId, TableChangeLogCommon<L>>,
    pub state_table_info: HummockVersionStateTableInfo,
}

Fields

id: HummockVersionId

levels: HashMap<CompactionGroupId, LevelsCommon<T>>

max_committed_epoch: u64

👎Deprecated

table_watermarks: HashMap<TableId, Arc<TableWatermarks>>

table_change_log: HashMap<TableId, TableChangeLogCommon<L>>

state_table_info: HummockVersionStateTableInfo

Implementations

impl<L> HummockVersionCommon<SstableInfo, L>

pub fn get_compaction_group_levels( &self, compaction_group_id: CompactionGroupId, ) -> &Levels

pub fn get_compaction_group_levels_mut( &mut self, compaction_group_id: CompactionGroupId, ) -> &mut Levels

pub fn get_sst_ids_by_group_id( &self, compaction_group_id: CompactionGroupId, ) -> impl Iterator<Item = HummockSstableId> + '_

pub fn level_iter<F: FnMut(&Level) -> bool>( &self, compaction_group_id: CompactionGroupId, f: F, )

pub fn num_levels(&self, compaction_group_id: CompactionGroupId) -> usize

pub fn safe_epoch_table_watermarks( &self, existing_table_ids: &[u32], ) -> BTreeMap<u32, TableWatermarks>

impl<L: Clone> HummockVersionCommon<SstableInfo, L>

pub fn count_new_ssts_in_group_split( &self, parent_group_id: CompactionGroupId, split_key: Bytes, ) -> u64

pub fn init_with_parent_group( &mut self, parent_group_id: CompactionGroupId, group_id: CompactionGroupId, member_table_ids: BTreeSet<StateTableId>, new_sst_start_id: HummockSstableId, )

pub fn build_sst_delta_infos( &self, version_delta: &HummockVersionDeltaCommon<SstableInfo, L>, ) -> Vec<SstDeltaInfo>

pub fn apply_version_delta( &mut self, version_delta: &HummockVersionDeltaCommon<SstableInfo, L>, )

pub fn apply_change_log_delta<T: Clone>( table_change_log: &mut HashMap<TableId, TableChangeLogCommon<T>>, change_log_delta: &HashMap<TableId, ChangeLogDeltaCommon<T>>, removed_table_ids: &HashSet<TableId>, state_table_info_delta: &HashMap<TableId, StateTableInfoDelta>, changed_table_info: &HashMap<TableId, Option<StateTableInfo>>, )

pub fn build_branched_sst_info( &self, ) -> BTreeMap<HummockSstableObjectId, BranchedSstInfo>

pub fn merge_compaction_group( &mut self, left_group_id: CompactionGroupId, right_group_id: CompactionGroupId, )

pub fn init_with_parent_group_v2( &mut self, parent_group_id: CompactionGroupId, group_id: CompactionGroupId, new_sst_start_id: HummockSstableId, split_key: Option<Bytes>, )

impl<T> HummockVersionCommon<T>

where T: SstableIdReader + ObjectIdReader,

pub fn get_sst_object_ids( &self, exclude_change_log: bool, ) -> HashSet<HummockSstableObjectId>

pub fn get_object_ids( &self, exclude_change_log: bool, ) -> HashSet<HummockObjectId>

pub fn get_sst_ids(&self, exclude_change_log: bool) -> HashSet<HummockSstableId>

pub fn get_sst_infos( &self, exclude_change_log: bool, ) -> impl Iterator<Item = &T>

impl<T, L> HummockVersionCommon<T, L>

pub fn get_combined_levels(&self) -> impl Iterator<Item = &LevelCommon<T>> + '_

impl<T> HummockVersionCommon<T>

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

pub fn from_rpc_protobuf(pb_version: &PbHummockVersion) -> Self

Convert the PbHummockVersion received from rpc to HummockVersion. No need to maintain backward compatibility.

pub fn from_persisted_protobuf(pb_version: &PbHummockVersion) -> Self

Convert the PbHummockVersion deserialized from persisted state to HummockVersion. We should maintain backward compatibility.

pub fn to_protobuf(&self) -> PbHummockVersion

impl HummockVersionCommon<SstableInfo>

pub fn estimated_encode_len(&self) -> usize

impl HummockVersionCommon<SstableInfo>

pub fn next_version_id(&self) -> HummockVersionId

pub fn need_fill_backward_compatible_state_table_info_delta(&self) -> bool

pub fn may_fill_backward_compatible_state_table_info_delta( &self, delta: &mut HummockVersionDelta, )

pub fn create_init_version( default_compaction_config: Arc<CompactionConfig>, ) -> HummockVersion

pub fn version_delta_after(&self) -> HummockVersionDelta

pub fn split_change_log( self, ) -> (LocalHummockVersion, HashMap<TableId, TableChangeLog>)

impl<T, L> HummockVersionCommon<T, L>

pub fn table_committed_epoch(&self, table_id: TableId) -> Option<u64>

Trait Implementations

impl<T: Clone, L: Clone> Clone for HummockVersionCommon<T, L>

fn clone(&self) -> HummockVersionCommon<T, L>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug, L: Debug> Debug for HummockVersionCommon<T, L>

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

Formats the value using the given formatter.

impl<T> From<&HummockVersion> for HummockVersionCommon<T>

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

fn from(pb_version: &PbHummockVersion) -> Self

Converts to this type from the input type.

impl<T> From<&HummockVersionCommon<T>> for PbHummockVersion

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

fn from(version: &HummockVersionCommon<T>) -> Self

Converts to this type from the input type.

impl From<HummockVersionCommon<SstableInfo>> for LocalHummockVersion

fn from(version: HummockVersion) -> Self

Converts to this type from the input type.

impl<T> From<HummockVersionCommon<T>> for PbHummockVersion

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

fn from(version: HummockVersionCommon<T>) -> Self

Converts to this type from the input type.

impl<T: PartialEq, L: PartialEq> PartialEq for HummockVersionCommon<T, L>

fn eq(&self, other: &HummockVersionCommon<T, L>) -> 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, L> StructuralPartialEq for HummockVersionCommon<T, L>