Struct MultiDimPartitionRule

pub struct MultiDimPartitionRule {
    partition_columns: Vec<String>,
    name_to_index: HashMap<String, usize>,
    regions: Vec<RegionNumber>,
    exprs: Vec<PartitionExpr>,
}

Multi-Dimiension partition rule. RFC here

This partition rule is defined by a set of simple expressions on the partition key columns. Compare to RANGE partition, which can be considered as single-dimension rule, this will evaluate expression on each column separately.

Fields

partition_columns: Vec<String>

Allow list of which columns can be used for partitioning.

name_to_index: HashMap<String, usize>

Name to index of partition_columns. Used for quick lookup.

regions: Vec<RegionNumber>

Region number for each partition. This list has the same length as exprs (dispiting the default region).

exprs: Vec<PartitionExpr>

Partition expressions.

Implementations

impl MultiDimPartitionRule

pub fn try_new( partition_columns: Vec<String>, regions: Vec<RegionNumber>, exprs: Vec<PartitionExpr>, ) -> Result<Self>

fn find_region(&self, values: &[Value]) -> Result<RegionNumber>

fn evaluate_expr(&self, expr: &PartitionExpr, values: &[Value]) -> Result<bool>

fn perform_op(lhs: &Value, op: &RestrictedOp, rhs: &Value) -> Result<bool>

Trait Implementations

impl Debug for MultiDimPartitionRule

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MultiDimPartitionRule

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartitionRule for MultiDimPartitionRule

fn as_any(&self) -> &dyn Any

fn partition_columns(&self) -> Vec<String>

fn find_region(&self, values: &[Value]) -> Result<RegionNumber>

Finds the target region by the partition values.

fn find_regions_by_exprs( &self, _exprs: &[PartitionExpr], ) -> Result<Vec<RegionNumber>>

Finds the target regions by the partition expressions.

impl Serialize for MultiDimPartitionRule

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.