Skip to content

Commit 5823aa1

Browse files
committed
chore(cubestore): Upgrade DF: Fix pretty-printing of physical plan Scan predicates
1 parent 0d8344f commit 5823aa1

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

rust/cubestore/cubestore-sql-tests/src/tests.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4009,15 +4009,15 @@ async fn planning_3_table_joins(service: Box<dyn SqlClient>) {
40094009
\n MergeJoin, on: [customer_id@1 = customer_id@0]\
40104010
\n CoalesceBatches\
40114011
\n Filter, predicate: product_id@2 = 125\
4012-
\n Scan, index: by_product_customer:3:[3]:sort_on[product_id, customer_id], fields: [order_id, customer_id, product_id], predicate: BinaryExpr(BinaryExpr { left: Column(Column { relation: None, name: \"product_id\" }), op: Eq, right: Literal(Int64(125)) })\
4012+
\n Scan, index: by_product_customer:3:[3]:sort_on[product_id, customer_id], fields: [order_id, customer_id, product_id], predicate: product_id = Int64(125)\
40134013
\n Sort\
40144014
\n Empty\
40154015
\n Scan, index: default:4:[4]:sort_on[customer_id], fields: *\
40164016
\n Sort\
40174017
\n Empty\
40184018
\n CoalesceBatches\
40194019
\n Filter, predicate: product_id@0 = 125\
4020-
\n Scan, index: default:5:[5]:sort_on[product_id], fields: *, predicate: BinaryExpr(BinaryExpr { left: Column(Column { relation: None, name: \"product_id\" }), op: Eq, right: Literal(Int64(125)) })\
4020+
\n Scan, index: default:5:[5]:sort_on[product_id], fields: *, predicate: product_id = Int64(125)\
40214021
\n Sort\
40224022
\n Empty",
40234023
);

rust/cubestore/cubestore/src/queryplanner/pretty_printers.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -528,7 +528,7 @@ fn pp_phys_plan_indented(p: &dyn ExecutionPlan, indent: usize, o: &PPOptions, ou
528528
);
529529
}
530530
if o.show_filters && t.filter.is_some() {
531-
*out += &format!(", predicate: {:?}", t.filter.as_ref().unwrap())
531+
*out += &format!(", predicate: {}", t.filter.as_ref().unwrap())
532532
}
533533
} else if let Some(_) = a.downcast_ref::<EmptyExec>() {
534534
*out += "Empty";

0 commit comments

Comments
 (0)