We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d70cb49 commit fab464dCopy full SHA for fab464d
1 file changed
datafusion/physical-plan/src/buffer.rs
@@ -92,8 +92,15 @@ impl BufferExec {
92
}
93
94
impl DisplayAs for BufferExec {
95
- fn fmt_as(&self, _t: DisplayFormatType, f: &mut fmt::Formatter) -> fmt::Result {
96
- write!(f, "{}: queue_size_bytes={}", self.name(), self.capacity)
+ fn fmt_as(&self, t: DisplayFormatType, f: &mut fmt::Formatter) -> fmt::Result {
+ match t {
97
+ DisplayFormatType::Default | DisplayFormatType::Verbose => {
98
+ write!(f, "BufferExec: capacity={}", self.capacity)
99
+ }
100
+ DisplayFormatType::TreeRender => {
101
+ writeln!(f, "target_batch_size={}", self.capacity)
102
103
104
105
106
0 commit comments