[fix] rename create_executor

Author: rdettai

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)
     }

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)
     }

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)
     }

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>>,

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)
     }

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,