Enum Aggregate 

pub enum Aggregate {
    MinK {
        keys: Vec<Key>,
        k: u32,
    },
    MaxK {
        keys: Vec<Key>,
        k: u32,
    },
}

Aggregation function applied within each group.

Determines which records to keep from each group and their ordering.

Variants

• MinK - Returns k records with minimum values (ascending order). Use with Key::Score to get best matches (lower score = better in Chroma).
• MaxK - Returns k records with maximum values (descending order).

Multi-level Ordering

The keys field supports multi-level ordering. Records are sorted by the first key, then by the second key for ties, and so on.

Examples

use chroma_types::operator::{Aggregate, Key};

// Best 3 by score per group
let agg = Aggregate::MinK {
    keys: vec![Key::Score],
    k: 3,
};

// Best 3 by score, then by date for ties
let agg = Aggregate::MinK {
    keys: vec![Key::Score, Key::field("date")],
    k: 3,
};

// Top 5 by recency (highest date first)
let agg = Aggregate::MaxK {
    keys: vec![Key::field("date")],
    k: 5,
};

Variants

MinK

Returns k records with minimum values (ascending order)

Fields

keys: Vec<Key>

Keys for multi-level ordering

k: u32

Number of records to return per group

MaxK

Returns k records with maximum values (descending order)

Fields

keys: Vec<Key>

Keys for multi-level ordering

k: u32

Number of records to return per group

Trait Implementations

impl Clone for Aggregate

fn clone(&self) -> Aggregate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Aggregate

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Aggregate

fn deserialize<__D>( __deserializer: __D, ) -> Result<Aggregate, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Aggregate

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<Aggregate> for Aggregate

type Error = QueryConversionError

The type returned in the event of a conversion error.

fn try_from( value: Aggregate, ) -> Result<Aggregate, <Aggregate as TryFrom<Aggregate>>::Error>

Performs the conversion.