Skip to content

Commit 079ddb0

Browse files
Standing-Manalamb
andauthored
implement tree explain for CoalesceBatchesExec (#15194)
* feat: implement tree explain for CoalesceBatchesExec Signed-off-by: Alan Tang <[email protected]> * chore: only fix on tree rendering Signed-off-by: Alan Tang <[email protected]> * feat(test): Add tree rendering test for CoalesceBatchesExec with a limit Signed-off-by: Alan Tang <[email protected]> --------- Signed-off-by: Alan Tang <[email protected]> Co-authored-by: Andrew Lamb <[email protected]>
1 parent ce536c9 commit 079ddb0

File tree

2 files changed

+751
-602
lines changed

2 files changed

+751
-602
lines changed

datafusion/physical-plan/src/coalesce_batches.rs

+5-2
Original file line numberDiff line numberDiff line change
@@ -123,8 +123,11 @@ impl DisplayAs for CoalesceBatchesExec {
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)