From a4157b111d4ddd011b90dcfa2cad160cbbaf150a Mon Sep 17 00:00:00 2001
From: Devin D'Angelo <devinjdangelo@gmail.com>
Date: Fri, 4 Aug 2023 08:51:52 -0400
Subject: [PATCH] rename to execute streams for insertexec

---
 datafusion/core/src/physical_plan/insert.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/datafusion/core/src/physical_plan/insert.rs b/datafusion/core/src/physical_plan/insert.rs
index 11fee23d3b3e..622e33b117fd 100644
--- a/datafusion/core/src/physical_plan/insert.rs
+++ b/datafusion/core/src/physical_plan/insert.rs
@@ -96,7 +96,7 @@ impl InsertExec {
         }
     }
 
-    fn make_input_stream(
+    fn execute_input_stream(
         &self,
         partition: usize,
         context: Arc<TaskContext>,
@@ -136,14 +136,14 @@ impl InsertExec {
         }
     }
 
-    fn make_all_input_streams(
+    fn execute_all_input_streams(
         &self,
         context: Arc<TaskContext>,
     ) -> Result<Vec<SendableRecordBatchStream>> {
         let n_input_parts = self.input.output_partitioning().partition_count();
         let mut streams = Vec::with_capacity(n_input_parts);
         for part in 0..n_input_parts {
-            streams.push(self.make_input_stream(part, context.clone())?);
+            streams.push(self.execute_input_stream(part, context.clone())?);
         }
         Ok(streams)
     }
@@ -236,7 +236,7 @@ impl ExecutionPlan for InsertExec {
                 "InsertExec can only be called on partition 0!".into(),
             ));
         }
-        let data = self.make_all_input_streams(context.clone())?;
+        let data = self.execute_all_input_streams(context.clone())?;
 
         let count_schema = self.count_schema.clone();
         let sink = self.sink.clone();