From 05524b8d7f7a849b2c0352a31d12cc33bd29a5f0 Mon Sep 17 00:00:00 2001
From: Colin Ho <colinho@Colins-MBP.localdomain>
Date: Mon, 26 Aug 2024 18:03:25 -0700
Subject: [PATCH] remove printlns

---
 .../src/intermediate_ops/hash_join_probe.rs                     | 1 -
 .../src/intermediate_ops/intermediate_op.rs                     | 1 -
 src/daft-local-execution/src/sinks/hash_join_build.rs           | 2 +-
 3 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/src/daft-local-execution/src/intermediate_ops/hash_join_probe.rs b/src/daft-local-execution/src/intermediate_ops/hash_join_probe.rs
index 1541cb2341..b8a4053eb8 100644
--- a/src/daft-local-execution/src/intermediate_ops/hash_join_probe.rs
+++ b/src/daft-local-execution/src/intermediate_ops/hash_join_probe.rs
@@ -112,7 +112,6 @@ impl IntermediateOperator for HashJoinProbeOperator {
         input: &PipelineResultType,
         state: Option<&mut Box<dyn IntermediateOperatorState>>,
     ) -> DaftResult<IntermediateOperatorResult> {
-        println!("HashJoinProbeOperator::execute: idx: {}", idx);
         match idx {
             0 => {
                 let state = state
diff --git a/src/daft-local-execution/src/intermediate_ops/intermediate_op.rs b/src/daft-local-execution/src/intermediate_ops/intermediate_op.rs
index 9abf35c6f6..aec8e91be6 100644
--- a/src/daft-local-execution/src/intermediate_ops/intermediate_op.rs
+++ b/src/daft-local-execution/src/intermediate_ops/intermediate_op.rs
@@ -138,7 +138,6 @@ impl IntermediateNode {
         };
 
         for (idx, mut receiver) in receivers.into_iter().enumerate() {
-            println!("idx: {}", idx);
             let mut buffer = OperatorBuffer::new(morsel_size);
             while let Some(morsel) = receiver.recv().await {
                 if morsel.should_broadcast() {
diff --git a/src/daft-local-execution/src/sinks/hash_join_build.rs b/src/daft-local-execution/src/sinks/hash_join_build.rs
index 0a86756334..b7940d4ebe 100644
--- a/src/daft-local-execution/src/sinks/hash_join_build.rs
+++ b/src/daft-local-execution/src/sinks/hash_join_build.rs
@@ -95,6 +95,7 @@ impl BlockingSink for HashJoinBuildSink {
         self.probe_table_state.add_tables(input)?;
         Ok(BlockingSinkStatus::NeedMoreInput)
     }
+
     fn finalize(&mut self) -> DaftResult<Option<PipelineResultType>> {
         self.probe_table_state.finalize()?;
         if let ProbeTableState::Done {
@@ -102,7 +103,6 @@ impl BlockingSink for HashJoinBuildSink {
             tables,
         } = &self.probe_table_state
         {
-            println!("HashJoinBuildSink::finalize: table_len: {}", tables.len());
             Ok(Some((probe_table.clone(), tables.clone()).into()))
         } else {
             panic!("finalize should only be called after the probe table is built")