Skip to content

Commit 847a2bb

Browse files
committed
minor
1 parent 558b402 commit 847a2bb

File tree

1 file changed

+19
-4
lines changed
  • crates/integrations/datafusion/src/physical_plan

1 file changed

+19
-4
lines changed

crates/integrations/datafusion/src/physical_plan/write.rs

Lines changed: 19 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -95,14 +95,29 @@ impl IcebergWriteExec {
9595
}
9696

9797
impl Debug for IcebergWriteExec {
98-
fn fmt(&self, _f: &mut Formatter<'_>) -> std::fmt::Result {
99-
todo!()
98+
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
99+
write!(f, "IcebergWriteExec")
100100
}
101101
}
102102

103103
impl DisplayAs for IcebergWriteExec {
104-
fn fmt_as(&self, _t: DisplayFormatType, _f: &mut Formatter) -> std::fmt::Result {
105-
todo!()
104+
fn fmt_as(&self, t: DisplayFormatType, f: &mut Formatter) -> std::fmt::Result {
105+
match t {
106+
DisplayFormatType::Default => {
107+
write!(f, "IcebergWriteExec: table={}", self.table.identifier())
108+
}
109+
DisplayFormatType::Verbose => {
110+
write!(
111+
f,
112+
"IcebergWriteExec: table={}, result_schema={:?}",
113+
self.table.identifier(),
114+
self.result_schema
115+
)
116+
}
117+
DisplayFormatType::TreeRender => {
118+
write!(f, "IcebergWriteExec: table={}", self.table.identifier())
119+
}
120+
}
106121
}
107122
}
108123

0 commit comments

Comments
 (0)