Решение на упр.05 задача 2 от Константин Илиев
Към профила на Константин Илиев
Резултати
- 3 точки от тестове
- 0 бонус точки
- 3 точки общо
- 3 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::collections::HashMap;
use std::hash::Hash;
use std::fmt::{self, Display};
struct Event{
timestamp: u64,
sensor: String,
metric: SensorMetric,
value: f64,
}
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
enum SensorMetric{
Load,
Frequency,
Temperature,
}
impl Display for SensorMetric {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
let s = match self {
SensorMetric::Load => "Load",
SensorMetric::Frequency => "Frequency",
SensorMetric::Temperature => "Temperature",
};
write!(f, "{s}")
}
}
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 buckets: HashMap<K, Vec<D>> = HashMap::new();
for e in events{
if let Some(d) = data_fn(e){
let key = group_fn(e);
buckets.entry(key).or_default().push(d);
}
}
let mut result: HashMap<K, O> = HashMap::with_capacity(buckets.len());
for(key, vals) in buckets{
result.insert(key, aggregate(&vals));
}
result
}
trait Aggregator{
type Output;
fn name(&self) -> String;
fn aggregate(&self, events: &[Event]) -> Vec<(String, Self::Output)>;
}
fn avg(vec: &[f64]) -> f64{
if vec.is_empty(){
return f64::NAN;
}
let mut sum = 0.0;
for val in vec{
sum += *val;
}
sum / (vec.len() as f64)
}
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 by_metric: HashMap<SensorMetric, f64> = group_and_aggregate(
events,
|e| e.metric,
|e| Some(e.value),
|vals| avg(vals),
);
let mut result = Vec::new();
for i in [
SensorMetric::Load,
SensorMetric::Frequency,
SensorMetric::Temperature,
]{
let mean = match by_metric.get(&i){
Some(val) => *val,
None => f64::NAN,
};
result.push((i.to_string(), mean));
}
result
}
}
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 by_sensor: HashMap<String, f64> = group_and_aggregate(
events,
|e| e.sensor.clone(),
|e| {if e.metric == self.metric {Some(e.value)} else{ None }},
|vals| avg(vals),
);
let mut pairs: Vec<(String, f64)> = by_sensor.into_iter().collect();
pairs.sort_by(|a, b| a.0.cmp(&b.0));
pairs
}
}
Лог от изпълнението
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-sink v0.3.31
Compiling futures-core v0.3.31
Compiling futures-channel v0.3.31
Compiling memchr v2.7.6
Compiling syn v2.0.110
Compiling pin-utils v0.1.0
Compiling pin-project-lite v0.2.16
Compiling futures-io v0.3.31
Compiling futures-task v0.3.31
Compiling slab v0.4.11
Compiling solution v0.1.0 (/tmp/d20251113-1757769-1wg9j1x/solution)
warning: struct `Event` is never constructed
--> src/lib.rs:5:8
|
5 | struct Event{
| ^^^^^
|
= note: `#[warn(dead_code)]` on by default
warning: enum `SensorMetric` is never used
--> src/lib.rs:13:6
|
13 | enum SensorMetric{
| ^^^^^^^^^^^^
warning: function `group_and_aggregate` is never used
--> src/lib.rs:30:4
|
30 | fn group_and_aggregate<O, E, D, K>(
| ^^^^^^^^^^^^^^^^^^^
warning: trait `Aggregator` is never used
--> src/lib.rs:55:7
|
55 | trait Aggregator{
| ^^^^^^^^^^
warning: function `avg` is never used
--> src/lib.rs:62:4
|
62 | fn avg(vec: &[f64]) -> f64{
| ^^^
warning: struct `TotalAggregator` is never constructed
--> src/lib.rs:75:8
|
75 | struct TotalAggregator {}
| ^^^^^^^^^^^^^^^
warning: struct `MetricAggregator` is never constructed
--> src/lib.rs:110:8
|
110 | struct MetricAggregator{
| ^^^^^^^^^^^^^^^^
warning: `solution` (lib) generated 7 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:6:5
|
5 | struct Event{
| ----- field in this struct
6 | timestamp: u64,
| ^^^^^^^^^
|
= note: `#[warn(dead_code)]` on by default
warning: method `name` is never used
--> tests/../src/lib.rs:58:8
|
55 | trait Aggregator{
| ---------- method in this trait
...
58 | fn name(&self) -> String;
| ^^^^
warning: `solution` (test "solution_test") generated 2 warnings
Finished `test` profile [unoptimized + debuginfo] target(s) in 9.25s
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