From f85f66e366b246a036417c112d4a7c2dc6190c22 Mon Sep 17 00:00:00 2001
From: Remi Dettai <rdettai@gmail.com>
Date: Thu, 23 Sep 2021 10:45:02 +0200
Subject: [PATCH] [fix] rename create_executor

---
 datafusion/src/datasource/file_format/avro.rs    | 4 ++--
 datafusion/src/datasource/file_format/csv.rs     | 4 ++--
 datafusion/src/datasource/file_format/json.rs    | 4 ++--
 datafusion/src/datasource/file_format/mod.rs     | 2 +-
 datafusion/src/datasource/file_format/parquet.rs | 4 ++--
 datafusion/src/datasource/listing.rs             | 2 +-
 6 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/datafusion/src/datasource/file_format/avro.rs b/datafusion/src/datasource/file_format/avro.rs
index 1e8bba7c68d05..bb5083d547b7b 100644
--- a/datafusion/src/datasource/file_format/avro.rs
+++ b/datafusion/src/datasource/file_format/avro.rs
@@ -54,7 +54,7 @@ impl FileFormat for AvroFormat {
         Ok(Statistics::default())
     }
 
-    async fn create_executor(
+    async fn create_physical_plan(
         &self,
         schema: SchemaRef,
         files: Vec<Vec<PartitionedFile>>,
@@ -338,7 +338,7 @@ mod tests {
             .expect("Stats inference");
         let files = vec![vec![PartitionedFile { path: filename }]];
         let exec = format
-            .create_executor(schema, files, stats, projection, batch_size, &[], None)
+            .create_physical_plan(schema, files, stats, projection, batch_size, &[], None)
             .await?;
         Ok(exec)
     }
diff --git a/datafusion/src/datasource/file_format/csv.rs b/datafusion/src/datasource/file_format/csv.rs
index 6eaabfac7390d..a5b555053ef76 100644
--- a/datafusion/src/datasource/file_format/csv.rs
+++ b/datafusion/src/datasource/file_format/csv.rs
@@ -76,7 +76,7 @@ impl FileFormat for CsvFormat {
         Ok(Statistics::default())
     }
 
-    async fn create_executor(
+    async fn create_physical_plan(
         &self,
         schema: SchemaRef,
         files: Vec<Vec<PartitionedFile>>,
@@ -214,7 +214,7 @@ mod tests {
             .expect("Stats inference");
         let files = vec![vec![PartitionedFile { path: filename }]];
         let exec = format
-            .create_executor(schema, files, stats, projection, batch_size, &[], None)
+            .create_physical_plan(schema, files, stats, projection, batch_size, &[], None)
             .await?;
         Ok(exec)
     }
diff --git a/datafusion/src/datasource/file_format/json.rs b/datafusion/src/datasource/file_format/json.rs
index 5ad363e6aa91a..7357644af1fa3 100644
--- a/datafusion/src/datasource/file_format/json.rs
+++ b/datafusion/src/datasource/file_format/json.rs
@@ -72,7 +72,7 @@ impl FileFormat for JsonFormat {
         Ok(Statistics::default())
     }
 
-    async fn create_executor(
+    async fn create_physical_plan(
         &self,
         schema: SchemaRef,
         files: Vec<Vec<PartitionedFile>>,
@@ -188,7 +188,7 @@ mod tests {
             path: filename.to_owned(),
         }]];
         let exec = format
-            .create_executor(schema, files, stats, projection, batch_size, &[], None)
+            .create_physical_plan(schema, files, stats, projection, batch_size, &[], None)
             .await?;
         Ok(exec)
     }
diff --git a/datafusion/src/datasource/file_format/mod.rs b/datafusion/src/datasource/file_format/mod.rs
index d831919cc9bad..e08ebd615c802 100644
--- a/datafusion/src/datasource/file_format/mod.rs
+++ b/datafusion/src/datasource/file_format/mod.rs
@@ -59,7 +59,7 @@ pub trait FileFormat: Send + Sync {
     /// TODO group params into TableDescription(schema,files,stats) and
     /// ScanOptions(projection,batch_size,filters) to avoid too_many_arguments
     #[allow(clippy::too_many_arguments)]
-    async fn create_executor(
+    async fn create_physical_plan(
         &self,
         schema: SchemaRef,
         files: Vec<Vec<PartitionedFile>>,
diff --git a/datafusion/src/datasource/file_format/parquet.rs b/datafusion/src/datasource/file_format/parquet.rs
index e746d81a31729..39aa14de0b9f0 100644
--- a/datafusion/src/datasource/file_format/parquet.rs
+++ b/datafusion/src/datasource/file_format/parquet.rs
@@ -68,7 +68,7 @@ impl FileFormat for ParquetFormat {
         Ok(stats)
     }
 
-    async fn create_executor(
+    async fn create_physical_plan(
         &self,
         schema: SchemaRef,
         files: Vec<Vec<PartitionedFile>>,
@@ -534,7 +534,7 @@ mod tests {
             .expect("Stats inference");
         let files = vec![vec![PartitionedFile { path: filename }]];
         let exec = format
-            .create_executor(schema, files, stats, projection, batch_size, &[], None)
+            .create_physical_plan(schema, files, stats, projection, batch_size, &[], None)
             .await?;
         Ok(exec)
     }
diff --git a/datafusion/src/datasource/listing.rs b/datafusion/src/datasource/listing.rs
index d240f650a5730..cac9b36b3d51f 100644
--- a/datafusion/src/datasource/listing.rs
+++ b/datafusion/src/datasource/listing.rs
@@ -150,7 +150,7 @@ impl TableProvider for ListingTable {
         // create the execution plan
         self.options
             .format
-            .create_executor(
+            .create_physical_plan(
                 self.schema(),
                 partitioned_file_lists,
                 statistics,