diff --git a/datafusion/physical-plan/src/memory.rs b/datafusion/physical-plan/src/memory.rs index 28783ebcf358..6c878fe5297b 100644 --- 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