diff --git a/mixnet/ordering/src/bin/aggregate.rs b/mixnet/ordering/src/bin/aggregate.rs index 6cd5cc9..63bf11a 100644 --- a/mixnet/ordering/src/bin/aggregate.rs +++ b/mixnet/ordering/src/bin/aggregate.rs @@ -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) diff --git a/mixnet/ordering/src/bin/latency.rs b/mixnet/ordering/src/bin/latency.rs index de51b4f..c78ae35 100644 --- a/mixnet/ordering/src/bin/latency.rs +++ b/mixnet/ordering/src/bin/latency.rs @@ -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::().unwrap(); - let max = aggregated.max::().unwrap(); + let min = aggregated.min::().unwrap(); + let max = aggregated.max::().unwrap(); let mean = aggregated.mean().unwrap(); let median = aggregated.median().unwrap(); let std = aggregated.std(1).unwrap();