From 1acf7bd5d8af9f44bec88b9e7be80054f30a7f23 Mon Sep 17 00:00:00 2001 From: Alex Koshelev Date: Tue, 10 Dec 2024 15:51:18 -0800 Subject: [PATCH] Final version --- ipa-core/src/test_fixture/hybrid.rs | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/ipa-core/src/test_fixture/hybrid.rs b/ipa-core/src/test_fixture/hybrid.rs index 8609d7f62..335c8bd5f 100644 --- a/ipa-core/src/test_fixture/hybrid.rs +++ b/ipa-core/src/test_fixture/hybrid.rs @@ -256,14 +256,7 @@ pub fn hybrid_in_the_clear>>( max_breakdown: usize, ) -> Vec { let mut attributed_conversions = HashMap::::new(); - for (cnt, input) in input_rows.into_iter().enumerate() { - if cnt % 1_000_000 == 0 { - tracing::info!( - "processed another 1M rows: {}, size of conversions: {}", - cnt / 1_000_000, - attributed_conversions.len() - ); - } + for input in input_rows { match input.borrow() { r @ (TestHybridRecord::TestConversion { match_key, .. } | TestHybridRecord::TestImpression { match_key, .. }) => { @@ -274,15 +267,8 @@ pub fn hybrid_in_the_clear>>( } } } - tracing::info!("done attribution phase"); - - // let pairs = attributed_conversions - // .into_values() - // .filter_map(MatchEntry::into_breakdown_key_and_value_tuple) - // .collect::>(); let mut output = vec![0; max_breakdown]; - // for (breakdown_key, value) in attributed_conversions.into_values() { for entry in attributed_conversions.into_values() { if let Some((breakdown_key, value)) = entry.into_breakdown_key_and_value_tuple() { output[usize::try_from(breakdown_key).unwrap()] += value;