wip: remove loggin

Author: matthewgapp

datafusion/physical-expr/src/expressions/binary.rs

@@ -293,13 +293,6 @@ impl PhysicalExpr for BinaryExpr {
         let schema = batch.schema();
         let input_schema = schema.as_ref();
 
-        println!(
-            "evaluate binary on batch left {:?}, right {:?}, operator {:?}",
-            left_value, right_value, self.op
-        );
-
-        print_batches(&[batch.clone()]).unwrap();
-
         if self.is_datum_operator() {
             return match (&left_value, &right_value) {
                 (ColumnarValue::Array(left), ColumnarValue::Array(right)) => {

datafusion/physical-plan/src/continuance.rs

@@ -135,7 +135,6 @@ impl ExecutionPlan for ContinuanceExec {
         partition: usize,
         context: Arc<TaskContext>,
     ) -> Result<SendableRecordBatchStream> {
-        println!("calling execute on ContinuanceExec");
         // Continuance streams must be the plan base.
         if partition != 0 {
             return Err(DataFusionError::Internal(format!(

datafusion/physical-plan/src/recursive_query.rs

@@ -150,7 +150,6 @@ impl ExecutionPlan for RecursiveQueryExec {
         partition: usize,
         context: Arc<TaskContext>,
     ) -> Result<SendableRecordBatchStream> {
-        println!("recursive query exec execute");
         // All partitions must be coalesced before coming to RecursiveQueryExec.
         // TODO: we might be able to handle multiple partitions in the future.
         if partition != 0 {
@@ -307,10 +306,8 @@ impl RecursiveQueryStream {
             }
         }
 
-        println!("executing recursive term");
-
-        // let partition = self.task_context.set_and_increment_partition();
         let partition = 0;
+
         self.recursive_stream = Some(
             self.recursive_term
                 .execute(partition, self.task_context.clone())?,

datafusion/physical-plan/src/repartition/mod.rs

@@ -483,7 +483,6 @@ impl ExecutionPlan for RepartitionExec {
 
         // if this is the first partition to be invoked then we need to set up initial state
         if state.channels.is_empty() {
-            println!("channels are empty");
             let (txs, rxs) = if self.preserve_order {
                 let (txs, rxs) =
                     partition_aware_channels(num_input_partitions, num_output_partitions);
@@ -555,10 +554,6 @@ impl ExecutionPlan for RepartitionExec {
             partition
         );
 
-        println!("execute partition: {}", partition);
-        println!("channel number: {}", state.channels.len());
-        println!("preserve order {}", self.preserve_order);
-
         // now return stream for the specified *output* partition which will
         // read from the channel
         let (_tx, mut rx, reservation) = state
@@ -601,7 +596,6 @@ impl ExecutionPlan for RepartitionExec {
             )
         } else {
             let input = rx.swap_remove(0);
-            println!("input partition: {:?}", input);
             Ok(Box::pin(RepartitionStream {
                 num_input_partitions,
                 num_input_partitions_processed: 0,