Struct Partition

pub struct Partition {
    inner: RwLock<Inner>,
    dedup: bool,
}

A tree partition.

Fields

inner: RwLock<Inner>

dedup: bool

Whether to dedup batches.

Implementations

impl Partition

pub fn new(metadata: RegionMetadataRef, config: &PartitionTreeConfig) -> Self

Creates a new partition.

pub fn write_with_key( &self, primary_key: &mut Vec<u8>, row_codec: &dyn PrimaryKeyCodec, key_value: KeyValue<'_>, re_encode: bool, metrics: &mut WriteMetrics, ) -> Result<()>

Writes to the partition with a primary key.

pub fn write_no_key(&self, key_value: KeyValue<'_>) -> Result<()>

Writes to the partition without a primary key.

fn build_primary_key_filter( need_prune_key: bool, metadata: &RegionMetadataRef, row_codec: &dyn PrimaryKeyCodec, filters: &Arc<Vec<SimpleFilterEvaluator>>, ) -> Option<Box<dyn PrimaryKeyFilter>>

pub fn read(&self, context: ReadPartitionContext) -> Result<PartitionReader>

Scans data in the partition.

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

Freezes the partition.

pub fn fork( &self, metadata: &RegionMetadataRef, config: &PartitionTreeConfig, ) -> Partition

Forks the partition.

Must freeze the partition before fork.

pub fn has_data(&self) -> bool

Returns true if the partition has data.

pub(crate) fn stats(&self) -> PartitionStats

Gets the stats of the partition.

pub(crate) fn get_partition_key( key_value: &KeyValue<'_>, is_partitioned: bool, ) -> u32

Get partition key from the key value.

pub(crate) fn has_multi_partitions(metadata: &RegionMetadataRef) -> bool

Returns true if the region can be partitioned.

pub(crate) fn is_partition_column(name: &str) -> bool

Returns true if this is a partition column.