Struct AggregationPolicy 

pub struct AggregationPolicy {
    pub reducer: AggregationReducerName,
    pub trim_fraction: Option<f64>,
    pub threshold: Option<f64>,
    pub weight_column: Option<String>,
    pub custom_reducer_id: Option<String>,
}

Aggregation policy: which reducer collapses repeated predictions to one value per sample, plus the single parameter that reducer accepts. Parameters that do not belong to the chosen reducer must be absent (enforced by validate). None numeric parameters take the ADR-07 defaults (DEFAULT_TRIM_FRACTION, DEFAULT_THRESHOLD).

Fields

reducer: AggregationReducerName

trim_fraction: Option<f64>

robust_mean trim fraction in [0.0, 0.5).

threshold: Option<f64>

exclude_outliers confidence threshold in (0.0, 1.0).

weight_column: Option<String>

weighted_mean provider-supplied per-row weight column.

custom_reducer_id: Option<String>

custom host-controller reducer id.

Implementations

impl AggregationPolicy

pub fn validate(&self) -> Result<(), DataError>

Validate the reducer and its parameters: the reducer’s own parameter is range-checked, and any parameter belonging to a different reducer must be absent. No task context (see validate_for_task).

pub fn validate_for_task( &self, task: PredictionTaskKind, ) -> Result<(), DataError>

Validate parameters and refuse task-incompatible reducers (vote on a regression task), raising DataError::IncompatibleReducer.

Trait Implementations

impl Clone for AggregationPolicy

fn clone(&self) -> AggregationPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AggregationPolicy

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AggregationPolicy

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for AggregationPolicy

fn eq(&self, other: &AggregationPolicy) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for AggregationPolicy

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 StructuralPartialEq for AggregationPolicy