We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ada0e9a commit 375c446Copy full SHA for 375c446
1 file changed
datafusion-federation/src/sql/mod.rs
@@ -287,9 +287,12 @@ impl DisplayAs for VirtualExecutionPlan {
287
if let Some(ctx) = self.executor.compute_context() {
288
write!(f, " compute_context={ctx}")?;
289
};
290
- let mut plan = self.plan.clone();
+ let mut plan = match RewriteTableScanAnalyzer::rewrite(self.plan.clone()) {
291
+ Ok(plan) => plan,
292
+ Err(_) => self.plan.clone(),
293
+ };
294
if let Ok(statement) = self.plan_to_statement(&plan) {
- write!(f, " initial_sql={statement}")?;
295
+ write!(f, " base_sql={statement}")?;
296
}
297
298
let (logical_optimizers, ast_analyzers) = match gather_analyzers(&plan) {
0 commit comments