use compute properties

apache · Jan 10, 2025 · 577b47f · 577b47f
1 parent dc1952a
commit 577b47f
Showing 1 changed file with 3 additions and 11 deletions.
diff --git a/datafusion/physical-plan/src/memory.rs b/datafusion/physical-plan/src/memory.rs
@@ -254,9 +254,10 @@ impl MemoryExec {
             }
         }
 
-        let cache = Self::compute_properties_as_value(Arc::clone(&schema));
+        let partitions = vec![batches];
+        let cache = Self::compute_properties(Arc::clone(&schema), &[], &partitions);
         Ok(Self {
-            partitions: vec![batches],
+            partitions,
             schema: Arc::clone(&schema),
             projected_schema: Arc::clone(&schema),
             projection: None,
@@ -385,15 +386,6 @@ impl MemoryExec {
             Boundedness::Bounded,
         )
     }
-
-    fn compute_properties_as_value(schema: SchemaRef) -> PlanProperties {
-        PlanProperties::new(
-            EquivalenceProperties::new(schema),
-            Partitioning::UnknownPartitioning(1),
-            EmissionType::Incremental,
-            Boundedness::Bounded,
-        )
-    }
 }
 
 /// Iterator over batches