aggregate: handle num_mixes_sending_data column

This commit is contained in:
Youngjoon Lee 2024-09-26 11:12:11 +09:00
parent b1b5d87528
commit c71edb2ca8
No known key found for this signature in database
GPG Key ID: 167546E2D1712F8C

View File

@ -20,6 +20,7 @@ fn aggregate(path: &str) {
schema.with_column("num_sender_msgs".into(), DataType::Int64);
schema.with_column("sender_data_msg_prob".into(), DataType::Float32);
schema.with_column("mix_data_msg_prob".into(), DataType::Float32);
schema.with_column("num_mixes_sending_data".into(), DataType::Int64);
schema.with_column("queue_type".into(), DataType::String);
schema.with_column("num_iterations".into(), DataType::Int64);