Skip to content

Commit ed9bba8

Browse files
committed
Minor: show output ordering in MemoryExec
1 parent e39b5ca commit ed9bba8

File tree

1 file changed

+14
-4
lines changed

1 file changed

+14
-4
lines changed

datafusion/core/src/physical_plan/memory.rs

Lines changed: 14 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,13 +68,23 @@ impl DisplayAs for MemoryExec {
6868
) -> std::fmt::Result {
6969
match t {
7070
DisplayFormatType::Default | DisplayFormatType::Verbose => {
71-
let partitions: Vec<_> =
71+
let partition_sizes: Vec<_> =
7272
self.partitions.iter().map(|b| b.len()).collect();
73+
74+
let output_ordering = self
75+
.sort_information
76+
.as_ref()
77+
.map(|output_ordering| {
78+
let order_strings: Vec<_> =
79+
output_ordering.iter().map(|e| e.to_string()).collect();
80+
format!(", output_ordering: {}", order_strings.join(","))
81+
})
82+
.unwrap_or_else(|| "".to_string());
83+
7384
write!(
7485
f,
75-
"MemoryExec: partitions={}, partition_sizes={:?}",
76-
partitions.len(),
77-
partitions
86+
"MemoryExec: partitions={}, partition_sizes={partition_sizes:?}{output_ordering}",
87+
partition_sizes.len(),
7888
)
7989
}
8090
}

0 commit comments

Comments
 (0)