risingwave_storage::hummock::compactor::shared_buffer_compact

Function generate_splits

source
fn generate_splits(
    payload: &Vec<ImmutableMemtable>,
    existing_table_ids: &HashSet<u32>,
    storage_opts: &StorageOpts,
) -> (Vec<KeyRange>, u64, BTreeMap<u32, u32>)
Expand description

Based on the incoming payload and opts, calculate the sharding method and sstable size of shared buffer compaction.