Skip to content

Commit 068f53c

Browse files
committed
feat: implement tree explain for CoalesceBatchesExec
Signed-off-by: Alan Tang <[email protected]>
1 parent eb62e28 commit 068f53c

File tree

2 files changed

+684
-603
lines changed

2 files changed

+684
-603
lines changed

datafusion/physical-plan/src/coalesce_batches.rs

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -117,14 +117,17 @@ impl DisplayAs for CoalesceBatchesExec {
117117
self.target_batch_size,
118118
)?;
119119
if let Some(fetch) = self.fetch {
120-
write!(f, ", fetch={fetch}")?;
120+
write!(f, ", limit={fetch}")?;
121121
};
122122

123123
Ok(())
124124
}
125125
DisplayFormatType::TreeRender => {
126-
// TODO: collect info
127-
write!(f, "")
126+
writeln!(f, "target_batch_size={}", self.target_batch_size)?;
127+
if let Some(fetch) = self.fetch {
128+
write!(f, "limit={fetch}")?;
129+
};
130+
Ok(())
128131
}
129132
}
130133
}

0 commit comments

Comments
 (0)