Enum PartitionStrategy 

pub enum PartitionStrategy {
    Hash {
        columns: Vec<String>,
        num_partitions: u32,
    },
    Range {
        column: String,
        boundaries: Vec<RangeBoundary>,
    },
    List {
        column: String,
        mappings: Vec<ListMapping>,
    },
    RoundRobin {
        num_partitions: u32,
    },
    Time {
        column: String,
        interval: TimeInterval,
    },
}

Strategy for partitioning data.

Variants

Hash

Hash-based partitioning (consistent hashing).

Fields

columns: Vec<String>

Column(s) to use for hashing.

num_partitions: u32

Number of partitions.

Range

Range-based partitioning.

Fields

column: String

Column to use for range partitioning.

boundaries: Vec<RangeBoundary>

Range boundaries.

List

List-based partitioning.

Fields

column: String

Column to use for list partitioning.

mappings: Vec<ListMapping>

Value to partition mapping.

RoundRobin

Round-robin partitioning.

Fields

num_partitions: u32

Number of partitions.

Time

Time-based partitioning.

Fields

column: String

Column containing timestamp.

interval: TimeInterval

Time interval for each partition.

Implementations

impl PartitionStrategy

pub fn hash(columns: Vec<String>, num_partitions: u32) -> Self

Create a hash partition strategy.

pub fn range(column: String, boundaries: Vec<RangeBoundary>) -> Self

Create a range partition strategy.

pub fn list(column: String, mappings: Vec<ListMapping>) -> Self

Create a list partition strategy.

pub fn round_robin(num_partitions: u32) -> Self

Create a round-robin partition strategy.

pub fn time(column: String, interval: TimeInterval) -> Self

Create a time-based partition strategy.

pub fn partition_for_key(&self, key: &PartitionKey) -> u32

Get the partition for a key.

Trait Implementations

impl Clone for PartitionStrategy

fn clone(&self) -> PartitionStrategy

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PartitionStrategy

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PartitionStrategy

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PartitionStrategy

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

where __S: Serializer,

Serialize this value into the given Serde serializer.