Struct TimePartitions 

pub struct TimePartitions {
    inner: Mutex<PartitionsInner>,
    part_duration: Duration,
    metadata: RegionMetadataRef,
    builder: MemtableBuilderRef,
    primary_key_codec: Arc<dyn PrimaryKeyCodec>,
    bulk_schema: Option<SchemaRef>,
}

Partitions.

Fields

inner: Mutex<PartitionsInner>

Mutable data of partitions.

part_duration: Duration

Duration of a partition.

metadata: RegionMetadataRef

Metadata of the region.

builder: MemtableBuilderRef

Builder of memtables.

primary_key_codec: Arc<dyn PrimaryKeyCodec>

Primary key encoder.

bulk_schema: Option<SchemaRef>

Cached schema for bulk insert. This field is Some if the memtable uses bulk insert.

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 write_bulk(&self, part: BulkPart) -> Result<()>

fn get_or_create_time_partition( &self, part_start: Timestamp, inner: &mut MutexGuard<'_, PartitionsInner>, ) -> Result<TimePartition>

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) -> 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 find_partitions_by_time_range<'a>( &self, ts_array: &ArrayRef, existing_parts: &'a [TimePartition], min: Timestamp, max: Timestamp, ) -> Result<(Vec<&'a TimePartition>, Vec<Timestamp>)>

Find existing partitions that match the bulk data’s time range and identify any new partitions that need to be created

fn part_duration_or_default(&self) -> Duration

Returns partition duration, or use default 1day duration is not present.

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

Write to multiple partitions.

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

Timeseries count in all time partitions.

Trait Implementations

impl Debug for TimePartitions

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

Formats the value using the given formatter.