MemoryExec INSERT INTO refactor to use ExecutionPlan (apache#6049)

* MemoryExec insert into refactor * Merge leftovers * Set target partition * Comment and formatting improvements * Comments on state. * Letfover comments * After merge corrections * Correction after merge --------- Co-authored-by: Mehmet Ozan Kabak <[email protected]>
tustvold · Apr 28, 2023 · d5a8c93 · d5a8c93
1 parent 191af8d
commit d5a8c93
Show file tree

Hide file tree

Showing 5 changed files with 800 additions and 173 deletions.
diff --git a/datafusion/core/src/datasource/datasource.rs b/datafusion/core/src/datasource/datasource.rs
@@ -102,8 +102,8 @@ pub trait TableProvider: Sync + Send {
     async fn insert_into(
         &self,
         _state: &SessionState,
-        _input: &LogicalPlan,
-    ) -> Result<()> {
+        _input: Arc<dyn ExecutionPlan>,
+    ) -> Result<Arc<dyn ExecutionPlan>> {
         let msg = "Insertion not implemented for this table".to_owned();
         Err(DataFusionError::NotImplemented(msg))
     }