Struct HummockVersionCommon

pub struct HummockVersionCommon<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<T>>,
    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<T>>

state_table_info: HummockVersionStateTableInfo

Implementations

impl HummockVersionCommon<SstableInfo>

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 = u64> + '_

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

get_sst_infos_from_groups doesn’t guarantee that all returned sst info belongs to select_group. i.e. select_group is just a hint. We separate get_sst_infos_from_groups and get_sst_infos because get_sst_infos_from_groups may be further customized in the future.

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 HummockVersionCommon<SstableInfo>

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: u64, )

pub fn build_sst_delta_infos( &self, version_delta: &HummockVersionDelta, ) -> Vec<SstDeltaInfo>

pub fn apply_version_delta(&mut self, version_delta: &HummockVersionDelta)

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: u64, split_key: Option<Bytes>, )

impl<T> HummockVersionCommon<T>

where T: SstableIdReader + ObjectIdReader,

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

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

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

pub fn get_sst_infos(&self) -> impl Iterator<Item = &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 table_committed_epoch(&self, table_id: TableId) -> Option<u64>

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

pub fn version_delta_after(&self) -> HummockVersionDelta

Trait Implementations

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

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

Returns a copy of the value.

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

Performs copy-assignment from source.

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

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<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> PartialEq for HummockVersionCommon<T>

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