Решение на упр.05 задача 2 от Илиян Свечев
Резултати
- 3 точки от тестове
- 0 бонус точки
- 3 точки общо
- 3 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::collections::HashMap;
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 + std::hash::Hash,
D: Clone
{
let mut grouped: HashMap<K, Vec<&E>> = HashMap::new();
for event in events {
if !grouped.contains_key(&group_fn(event)) {
grouped.insert(group_fn(event), [].to_vec());
}
grouped.get_mut(&group_fn(event)).unwrap().push(event);
}
let mut result: HashMap<K, O> = HashMap::new();
for (key, group) in grouped {
let mut data: Vec<D> = [].to_vec();
for event in group {
data.push(data_fn(event).unwrap());
}
result.insert(key, aggregate(&data));
}
result
}
trait Aggregator {
type Output;
fn name(&self) -> String;
fn aggregate(&self, events: &[Event]) -> Vec<(String, Self::Output)>;
}
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 = |data:&[f64]| {
let mut sum: f64 = 0.0;
for d in data {
println!("we are adding {d}!");
sum += d;
}
println!("sum is {}, avg is {}\n", sum, sum / data.len() as f64);
sum / data.len() as f64
};
let averages = group_and_aggregate(events, group_fn, data_fn, aggregate);
let mut res: Vec<(String, f64)> = [].to_vec();
for (key, val) in averages {
match key {
SensorMetric::Load => {
res.push(("Load".to_string(), val));
}
SensorMetric::Frequency => {
res.push(("Frequency".to_string(), val));
}
SensorMetric::Temperature => {
res.push(("Temperature".to_string(), val));
}
}
}
res
}
}
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 filtered: Vec<&Event> = events.iter().filter(|e| {e.metric == self.metric}).collect();
let group_fn = |e:&&Event| {e.sensor.clone()};
let data_fn = |e:&&Event| {Some(e.value)};
let aggregate = |data:&[f64]| {
let mut sum: f64 = 0.0;
for d in data {
sum += d;
}
sum / data.len() as f64
};
let sums = group_and_aggregate(&filtered, group_fn, data_fn, aggregate);
let mut res: Vec<(String, f64)> = [].to_vec();
for (key, val) in sums {
res.push((key, val));
}
res
}
}
Лог от изпълнението
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-core v0.3.31
Compiling futures-sink v0.3.31
Compiling futures-channel v0.3.31
Compiling pin-project-lite v0.2.16
Compiling futures-task v0.3.31
Compiling syn v2.0.110
Compiling memchr v2.7.6
Compiling futures-io v0.3.31
Compiling pin-utils v0.1.0
Compiling slab v0.4.11
Compiling solution v0.1.0 (/tmp/d20251113-1757769-122m4r/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:47:7
|
47 | trait Aggregator {
| ^^^^^^^^^^
warning: struct `TotalAggregator` is never constructed
--> src/lib.rs:55:8
|
55 | struct TotalAggregator {}
| ^^^^^^^^^^^^^^^
warning: struct `MetricAggregator` is never constructed
--> src/lib.rs:94:8
|
94 | 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:50:8
|
47 | trait Aggregator {
| ---------- method in this trait
...
50 | fn name(&self) -> String;
| ^^^^
warning: `solution` (test "solution_test") generated 2 warnings
Finished `test` profile [unoptimized + debuginfo] target(s) in 9.21s
Running tests/solution_test.rs (target/debug/deps/solution_test-f75e629a1d90e17c)
running 3 tests
test solution_test::test_by_metric ... ok
test solution_test::test_by_metric_2 ... 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