in src/dataset_exec.rs [245:276]
fn fmt_as(&self, t: DisplayFormatType, f: &mut std::fmt::Formatter) -> std::fmt::Result {
Python::with_gil(|py| {
let number_of_fragments = self.fragments.as_ref(py).len();
match t {
DisplayFormatType::Default | DisplayFormatType::Verbose => {
let projected_columns: Vec<String> = self
.schema
.fields()
.iter()
.map(|x| x.name().to_owned())
.collect();
if let Some(filter_expr) = &self.filter_expr {
let filter_expr = filter_expr.as_ref(py).str().or(Err(std::fmt::Error))?;
write!(
f,
"DatasetExec: number_of_fragments={}, filter_expr={}, projection=[{}]",
number_of_fragments,
filter_expr,
projected_columns.join(", "),
)
} else {
write!(
f,
"DatasetExec: number_of_fragments={}, projection=[{}]",
number_of_fragments,
projected_columns.join(", "),
)
}
}
}
})
}