logos-blockchain/logos-blockchain-simulations
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-simulations.git synced 2026-01-20 05:53:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

use f64

Browse Source
This commit is contained in:
Youngjoon Lee 2024-09-26 10:53:41 +09:00
parent ab7d09558a
commit b35c3d7ec5
No known key found for this signature in database
GPG Key ID: 167546E2D1712F8C
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
mixnet/ordering/src/bin/aggregate.rs
View File

@ -71,11 +71,11 @@ fn aggregate(path: &str) {
fn add_stats_columns(df: &mut DataFrame, path: PathBuf, col_prefix: &str) {
let mut schema = Schema::new();
schema.with_column("min".into(), DataType::UInt64);
schema.with_column("min".into(), DataType::Float64);
schema.with_column("median".into(), DataType::Float64);
schema.with_column("mean".into(), DataType::Float64);
schema.with_column("std".into(), DataType::Float64);
schema.with_column("max".into(), DataType::UInt64);
schema.with_column("max".into(), DataType::Float64);
let stats_df = CsvReadOptions::default()
.with_has_header(true)

6
mixnet/ordering/src/bin/latency.rs
View File

@ -27,7 +27,7 @@ fn aggregate(path: &str) {
.extend(
&df.column("latency")
.unwrap()
.i64()
.f64()
.unwrap()
.clone()
.into_series(),
@ -44,8 +44,8 @@ fn aggregate(path: &str) {
}
fn save_stats(aggregated: &Series, outpath: &str) {
let min = aggregated.min::<i64>().unwrap();
let max = aggregated.max::<i64>().unwrap();
let min = aggregated.min::<f64>().unwrap();
let max = aggregated.max::<f64>().unwrap();
let mean = aggregated.mean().unwrap();
let median = aggregated.median().unwrap();
let std = aggregated.std(1).unwrap();