Решение на упр.05 задача 2 от Венислав Трендафилов

Обратно към всички решения

Към профила на Венислав Трендафилов

Код

use std::collections::HashMap;

use std::hash::Hash;

struct Event {

timestamp: u64,

sensor: String,

metric: SensorMetric,

value: f64,

}

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]

enum SensorMetric {

Load,

Frequency,

Temperature,

}

fn group_and_aggregate<O, E, D, K>(

events: &[E],

group_fn: impl Fn(&E) -> K,

data_fn: impl Fn(&E) -> Option<D>,

aggregate: impl Fn(&[D]) -> O,

) -> HashMap<K, O>

where

K: Eq + Hash,

{

let mut groups: HashMap<K, Vec<D>> = HashMap::new();

for event in events {

if let Some(data) = data_fn(event) {

let key = group_fn(event);

groups.entry(key).or_default().push(data);

}

}

let mut result: HashMap<K, O> = HashMap::new();

for (key, data_vec) in groups {

let agg_value = aggregate(&data_vec);

result.insert(key, agg_value);

}

result

}

trait Aggregator {

type Output;

fn name(&self) -> String;

fn aggregate(&self, events: &[Event]) -> Vec<(String, Self::Output)>;

}

// Имплементирайте агрегация, която връща средната стойност на метриките, групирани по тип.

// Резултата трябва да е вектор от три елемента:

// - ("Load", <средната стойност на Load метриките от всички сензори>)

// - ("Frequency", <средната стойност на Frequency метриките от всички сензори>)

// - ("Temperature", <средната стойност на Temperature метриките от всички сензори>)

struct TotalAggregator {}

impl Aggregator for TotalAggregator {

type Output = f64;

fn name(&self) -> String {

"total".to_string()

}

fn aggregate(&self, events: &[Event]) -> Vec<(String, f64)> {

let group_fn = |e: &Event| e.metric;

let data_fn = |e: &Event| Some(e.value);

let aggregate = |vals: &[f64]| {

let sum: f64 = vals.iter().sum();

sum / (vals.len() as f64)

};

let grouped = group_and_aggregate(events, group_fn, data_fn, aggregate);

let mut result = Vec::new();

for (metric, avg) in grouped {

let key = match metric {

SensorMetric::Load => "Load".to_string(),

SensorMetric::Frequency => "Frequency".to_string(),

SensorMetric::Temperature => "Temperature".to_string(),

};

result.push((key, avg));

}

result

}

}

// Имплементирайте агрегация, която по даден тип на метрика, връща сумата от метриките

// от този тип, групирани по сензор.

// Пример при `MetricAggreator { metric: SensorMetric::Load }`, може да върне:

// - ("cpu0", <средната стойност от Load метиките за сензор cpu0>)

// - ("cpu1", <средната стойност от Load метиките за сензор cpu1>)

// - ("gpu0", <средната стойност от Load метиките за сензор gpu0>)

struct MetricAggregator {

metric: SensorMetric

}

impl Aggregator for MetricAggregator {

type Output = f64;

fn name(&self) -> String {

format!("{:?}", self.metric)

}

fn aggregate(&self, events: &[Event]) -> Vec<(String, f64)> {

let target_metric: SensorMetric = self.metric;

let group_fn = |e: &Event| e.sensor.clone();

let data_fn = |e: &Event| {

if e.metric == target_metric {

Some(e.value)

} else {

None

}

};

let aggregate = |vals: &[f64]| {

let sum: f64 = vals.iter().sum();

sum / (vals.len() as f64)

};

let grouped = group_and_aggregate(events, group_fn, data_fn, aggregate);

let mut result = Vec::new();

for (sensor, avg) in grouped {

result.push((sensor, avg));

}

result

}

}

Лог от изпълнението

Updating crates.io index
     Locking 17 packages to latest compatible versions
   Compiling proc-macro2 v1.0.103
   Compiling quote v1.0.42
   Compiling unicode-ident v1.0.22
   Compiling futures-sink v0.3.31
   Compiling futures-core v0.3.31
   Compiling futures-channel v0.3.31
   Compiling slab v0.4.11
   Compiling syn v2.0.110
   Compiling pin-project-lite v0.2.16
   Compiling pin-utils v0.1.0
   Compiling memchr v2.7.6
   Compiling futures-task v0.3.31
   Compiling futures-io v0.3.31
   Compiling solution v0.1.0 (/tmp/d20251113-1757769-1p12vdo/solution)
warning: struct `Event` is never constructed
 --> src/lib.rs:3:8
  |
3 | struct Event {
  |        ^^^^^
  |
  = note: `#[warn(dead_code)]` on by default

warning: enum `SensorMetric` is never used
  --> src/lib.rs:11:6
   |
11 | enum SensorMetric {
   |      ^^^^^^^^^^^^

warning: function `group_and_aggregate` is never used
  --> src/lib.rs:17:4
   |
17 | fn group_and_aggregate<O, E, D, K>(
   |    ^^^^^^^^^^^^^^^^^^^

warning: trait `Aggregator` is never used
  --> src/lib.rs:41:7
   |
41 | trait Aggregator {
   |       ^^^^^^^^^^

warning: struct `TotalAggregator` is never constructed
  --> src/lib.rs:54:8
   |
54 | struct TotalAggregator {}
   |        ^^^^^^^^^^^^^^^

warning: struct `MetricAggregator` is never constructed
  --> src/lib.rs:91:8
   |
91 | struct MetricAggregator {
   |        ^^^^^^^^^^^^^^^^

warning: `solution` (lib) generated 6 warnings
   Compiling futures-macro v0.3.31
   Compiling futures-util v0.3.31
   Compiling futures-executor v0.3.31
   Compiling futures v0.3.31
warning: field `timestamp` is never read
 --> tests/../src/lib.rs:4:5
  |
3 | struct Event {
  |        ----- field in this struct
4 |     timestamp: u64,
  |     ^^^^^^^^^
  |
  = note: `#[warn(dead_code)]` on by default

warning: method `name` is never used
  --> tests/../src/lib.rs:44:8
   |
41 | trait Aggregator {
   |       ---------- method in this trait
...
44 |     fn name(&self) -> String;
   |        ^^^^

warning: `solution` (test "solution_test") generated 2 warnings
    Finished `test` profile [unoptimized + debuginfo] target(s) in 8.95s
     Running tests/solution_test.rs (target/debug/deps/solution_test-f75e629a1d90e17c)

running 3 tests
test solution_test::test_by_metric_2 ... ok
test solution_test::test_by_metric ... ok
test solution_test::test_total ... ok

test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s

История (1 версия и 0 коментара)