Type Alias HummockVersion

pub type HummockVersion = HummockVersionCommon<SstableInfo>;

Aliased Type

struct HummockVersion {
    pub id: HummockVersionId,
    pub levels: HashMap<u64, LevelsCommon<SstableInfo>>,
    pub(crate) max_committed_epoch: u64,
    pub table_watermarks: HashMap<TableId, Arc<TableWatermarks>>,
    pub table_change_log: HashMap<TableId, TableChangeLogCommon<SstableInfo>>,
    pub state_table_info: HummockVersionStateTableInfo,
}

Fields

id: HummockVersionId

levels: HashMap<u64, LevelsCommon<SstableInfo>>

max_committed_epoch: u64

👎Deprecated

table_watermarks: HashMap<TableId, Arc<TableWatermarks>>

table_change_log: HashMap<TableId, TableChangeLogCommon<SstableInfo>>

state_table_info: HummockVersionStateTableInfo

Implementations

impl HummockVersion

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 HummockVersion

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 HummockVersion

pub fn estimated_encode_len(&self) -> usize

impl HummockVersion

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 Default for HummockVersion

fn default() -> Self

Returns the “default value” for a type.