Решение на упр.05 задача 2 от Божидар Виденов

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

Към профила на Божидар Виденов

Код

use std::{collections::HashMap, 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 grouped_map: HashMap<K, Vec<D>> = HashMap::new();

for e in events {

let key = group_fn(e);

let data = data_fn(e);

if let None = data {

continue;

}

let data = data.unwrap();

По-добре би било

let data = match data {
    Some(d) => d,
    None => continue,
}

Препоръчително е да използваш директно pattern matching, вместо проверка и unwrap. При второто има някаква малка възможност за грешка (например при бъдещо рефакториране на кода), докато при първото компилатора ти гарантира, че всичко е наред.

Никола коментира преди 18 дена

match grouped_map.get_mut(&key) {

None => {

let mut data_v = Vec::new();

data_v.push(data);

grouped_map.insert(key, data_v);

}

Some(v) => v.push(data),

}

}

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

for (key, value) in grouped_map {

agg_map.insert(key, aggregate(&value.into_boxed_slice()));

Ненужно използване на into_boxed_slice.
value е от тип Vec<D>. aggregate(&value) автоматично ще го конвертира до &[D], защото съществува deref coersion от &Vec<D> до &[D].

От друга страна into_boxed_slice трябва да направи shrink_to_fit, което вероятно ще наложи да се реалокира целия вектор. Това се налага, защото типа Box<[D]> съдържа само ptr, len. Следователно трябва да върне алокирано парче памет с големина len, т.е. ако в оригиналния вектор len != cap, трябва да го реалокира за да махне излишния капацитет.

Никола коментира преди 18 дена

}

agg_map

}

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 TotalAggregator {

fn group_fn(event: &Event) -> String {

match event.metric {

SensorMetric::Load => String::from("Load"),

SensorMetric::Frequency => String::from("Frequency"),

SensorMetric::Temperature => String::from("Temperature"),

}

}

fn data_fn(event: &Event) -> Option<f64> {

Some(event.value)

}

//Fn(&[D]) -> O

fn agg_fn(items: &[f64]) -> f64 {

items.iter().sum::<f64>() / items.len() as f64

}

}

impl Aggregator for TotalAggregator {

type Output = f64;

fn name(&self) -> String {

"total".to_string()

}

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

group_and_aggregate(

events,

TotalAggregator::group_fn,

TotalAggregator::data_fn,

TotalAggregator::agg_fn,

)

.iter()

.map(|(k, v)| (k.clone(), v.clone()))

.collect::<Vec<(String, f64)>>()

}

}

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

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

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

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

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

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

struct MetricAggregator {

metric: SensorMetric,

}

impl MetricAggregator {

fn group_fn(event: &Event) -> String {

event.sensor.clone()

}

fn data_fn(event: &Event) -> Option<f64> {

match event.metric {

SensorMetric::Load => Some(event.value),

_ => None,

}

}

//Fn(&[D]) -> O

fn agg_fn(items: &[f64]) -> f64 {

items.iter().sum::<f64>() / items.len() as f64

}

}

impl Aggregator for MetricAggregator {

type Output = f64;

fn name(&self) -> String {

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

}

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

group_and_aggregate(

events,

MetricAggregator::group_fn,

MetricAggregator::data_fn,

MetricAggregator::agg_fn,

)

.iter()

.map(|(k, v)| (k.clone(), v.clone()))

.collect::<Vec<(String, f64)>>()

}

}

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

Updating crates.io index
     Locking 17 packages to latest compatible versions
   Compiling proc-macro2 v1.0.103
   Compiling unicode-ident v1.0.22
   Compiling quote v1.0.42
   Compiling futures-core v0.3.31
   Compiling futures-sink v0.3.31
   Compiling futures-channel v0.3.31
   Compiling pin-utils v0.1.0
   Compiling pin-project-lite v0.2.16
   Compiling slab v0.4.11
   Compiling syn v2.0.110
   Compiling futures-io v0.3.31
   Compiling futures-task v0.3.31
   Compiling memchr v2.7.6
   Compiling solution v0.1.0 (/tmp/d20251113-1757769-b36mpa/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:56:7
   |
56 | trait Aggregator {
   |       ^^^^^^^^^^

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

warning: associated functions `group_fn`, `data_fn`, and `agg_fn` are never used
  --> src/lib.rs:71:8
   |
70 | impl TotalAggregator {
   | -------------------- associated functions in this implementation
71 |     fn group_fn(event: &Event) -> String {
   |        ^^^^^^^^
...
79 |     fn data_fn(event: &Event) -> Option<f64> {
   |        ^^^^^^^
...
84 |     fn agg_fn(items: &[f64]) -> f64 {
   |        ^^^^^^

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

warning: associated functions `group_fn`, `data_fn`, and `agg_fn` are never used
   --> src/lib.rs:120:8
    |
119 | impl MetricAggregator {
    | --------------------- associated functions in this implementation
120 |     fn group_fn(event: &Event) -> String {
    |        ^^^^^^^^
...
124 |     fn data_fn(event: &Event) -> Option<f64> {
    |        ^^^^^^^
...
132 |     fn agg_fn(items: &[f64]) -> f64 {
    |        ^^^^^^

warning: `solution` (lib) generated 8 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:59:8
   |
56 | trait Aggregator {
   |       ---------- method in this trait
...
59 |     fn name(&self) -> String;
   |        ^^^^

warning: field `metric` is never read
   --> tests/../src/lib.rs:116:5
    |
115 | struct MetricAggregator {
    |        ---------------- field in this struct
116 |     metric: SensorMetric,
    |     ^^^^^^

warning: `solution` (test "solution_test") generated 3 warnings
    Finished `test` profile [unoptimized + debuginfo] target(s) in 8.82s
     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 версия и 2 коментара)