Skip to content

Commit 77d1326

Browse files
committed
WIP: Correct MemoryExec Debug logging
1 parent 62b4888 commit 77d1326

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

datafusion/physical-plan/src/memory.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,12 +56,14 @@ pub struct MemoryExec {
5656

5757
impl fmt::Debug for MemoryExec {
5858
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
59-
write!(f, "partitions: [...]")?;
60-
write!(f, "schema: {:?}", self.projected_schema)?;
59+
write!(f, "MemoryExec {{")?;
60+
write!(f, "partitions: [...], ")?;
61+
write!(f, "schema: {:?}, ", self.projected_schema)?;
6162
write!(f, "projection: {:?}", self.projection)?;
6263
if let Some(sort_info) = &self.sort_information.first() {
6364
write!(f, ", output_ordering: {:?}", sort_info)?;
6465
}
66+
write!(f, "}}")?;
6567
Ok(())
6668
}
6769
}

0 commit comments

Comments
 (0)