@@ -590,68 +590,6 @@ async fn explain_analyze_runs_optimizers() {
590
590
assert_contains ! ( actual, expected) ;
591
591
}
592
592
593
- #[ tokio:: test]
594
- async fn tpch_explain_q10 ( ) -> Result < ( ) > {
595
- let ctx = SessionContext :: new ( ) ;
596
-
597
- register_tpch_csv ( & ctx, "customer" ) . await ?;
598
- register_tpch_csv ( & ctx, "orders" ) . await ?;
599
- register_tpch_csv ( & ctx, "lineitem" ) . await ?;
600
- register_tpch_csv ( & ctx, "nation" ) . await ?;
601
-
602
- let sql = "select
603
- c_custkey,
604
- c_name,
605
- sum(l_extendedprice * (1 - l_discount)) as revenue,
606
- c_acctbal,
607
- n_name,
608
- c_address,
609
- c_phone,
610
- c_comment
611
- from
612
- customer,
613
- orders,
614
- lineitem,
615
- nation
616
- where
617
- c_custkey = o_custkey
618
- and l_orderkey = o_orderkey
619
- and o_orderdate >= date '1993-10-01'
620
- and o_orderdate < date '1994-01-01'
621
- and l_returnflag = 'R'
622
- and c_nationkey = n_nationkey
623
- group by
624
- c_custkey,
625
- c_name,
626
- c_acctbal,
627
- c_phone,
628
- n_name,
629
- c_address,
630
- c_comment
631
- order by
632
- revenue desc;" ;
633
-
634
- let dataframe = ctx. sql ( sql) . await . unwrap ( ) ;
635
- let plan = dataframe. into_optimized_plan ( ) . unwrap ( ) ;
636
-
637
- let expected = "\
638
- Sort: revenue DESC NULLS FIRST\
639
- \n Projection: customer.c_custkey, customer.c_name, SUM(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount) AS revenue, customer.c_acctbal, nation.n_name, customer.c_address, customer.c_phone, customer.c_comment\
640
- \n Aggregate: groupBy=[[customer.c_custkey, customer.c_name, customer.c_acctbal, customer.c_phone, nation.n_name, customer.c_address, customer.c_comment]], aggr=[[SUM(CAST(lineitem.l_extendedprice AS Decimal128(38, 4)) * CAST(Decimal128(Some(100),23,2) - CAST(lineitem.l_discount AS Decimal128(23, 2)) AS Decimal128(38, 4))) AS SUM(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)]]\
641
- \n Inner Join: customer.c_nationkey = nation.n_nationkey\
642
- \n Inner Join: orders.o_orderkey = lineitem.l_orderkey\
643
- \n Inner Join: customer.c_custkey = orders.o_custkey\
644
- \n TableScan: customer projection=[c_custkey, c_name, c_address, c_nationkey, c_phone, c_acctbal, c_comment]\
645
- \n Filter: orders.o_orderdate >= Date32(\" 8674\" ) AND orders.o_orderdate < Date32(\" 8766\" )\
646
- \n TableScan: orders projection=[o_orderkey, o_custkey, o_orderdate], partial_filters=[orders.o_orderdate >= Date32(\" 8674\" ), orders.o_orderdate < Date32(\" 8766\" )]\
647
- \n Filter: lineitem.l_returnflag = Utf8(\" R\" )\
648
- \n TableScan: lineitem projection=[l_orderkey, l_extendedprice, l_discount, l_returnflag], partial_filters=[lineitem.l_returnflag = Utf8(\" R\" )]\
649
- \n TableScan: nation projection=[n_nationkey, n_name]";
650
- assert_eq ! ( expected, format!( "{plan:?}" ) ) ;
651
-
652
- Ok ( ( ) )
653
- }
654
-
655
593
#[ tokio:: test]
656
594
async fn test_physical_plan_display_indent ( ) {
657
595
// Hard code target_partitions as it appears in the RepartitionExec output
0 commit comments