Struct TimePartitions

pub struct TimePartitions {
    inner: Mutex<PartitionsInner>,
    part_duration: Option<Duration>,
    metadata: RegionMetadataRef,
    builder: MemtableBuilderRef,
}

Partitions.

Fields

inner: Mutex<PartitionsInner>

Mutable data of partitions.

part_duration: Option<Duration>

Duration of a partition.

None means there is only one partition and the TimePartition::time_range is also None.

metadata: RegionMetadataRef

Metadata of the region.

builder: MemtableBuilderRef

Builder of memtables.

Implementations

impl TimePartitions

pub fn new( metadata: RegionMetadataRef, builder: MemtableBuilderRef, next_memtable_id: MemtableId, part_duration: Option<Duration>, ) -> Self

Returns a new empty partition list with optional duration.

pub fn write(&self, kvs: &KeyValues) -> Result<()>

Write key values to memtables.

It creates new partitions if necessary.

pub fn list_memtables(&self, memtables: &mut Vec<MemtableRef>)

Append memtables in partitions to memtables.

pub fn num_partitions(&self) -> usize

Returns the number of partitions.

pub fn is_empty(&self) -> bool

Returns true if all memtables are empty.

pub fn freeze(&self) -> Result<()>

Freezes all memtables.

pub fn fork( &self, metadata: &RegionMetadataRef, part_duration: Option<Duration>, ) -> Self

Forks latest partition and updates the partition duration if part_duration is Some.

pub(crate) fn part_duration(&self) -> Option<Duration>

Returns partition duration.

pub(crate) fn memory_usage(&self) -> usize

Returns memory usage.

pub(crate) fn num_rows(&self) -> u64

Returns the number of rows.

pub(crate) fn list_memtables_to_small_vec( &self, memtables: &mut SmallVec<[MemtableRef; 2]>, )

Append memtables in partitions to small vec.

pub(crate) fn next_memtable_id(&self) -> MemtableId

Returns the next memtable id.

pub(crate) fn new_with_part_duration( &self, part_duration: Option<Duration>, ) -> Self

Creates a new empty partition list from this list and a part_duration. It falls back to the old partition duration if part_duration is None.

fn list_partitions(&self) -> SmallVec<[TimePartition; 2]>

Returns all partitions.

fn write_multi_parts( &self, kvs: &KeyValues, parts: &SmallVec<[TimePartition; 2]>, ) -> Result<()>

Write to multiple partitions.

Trait Implementations

impl Debug for TimePartitions

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

Formats the value using the given formatter.