Skip to content

Commit ac3644d

Browse files
committed
feat: add project exec tree rendering for hash join
1 parent d83eff9 commit ac3644d

File tree

1 file changed

+54
-26
lines changed

1 file changed

+54
-26
lines changed

datafusion/sqllogictest/test_files/explain_tree.slt

Lines changed: 54 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -710,19 +710,33 @@ physical_plan
710710
18)└─────────────┬─────────────┘└─────────────┬─────────────┘
711711
19)┌─────────────┴─────────────┐┌─────────────┴─────────────┐
712712
20)│ ProjectionExec ││ RepartitionExec │
713-
21)└─────────────┬─────────────┘└─────────────┬─────────────┘
714-
22)┌─────────────┴─────────────┐┌─────────────┴─────────────┐
715-
23)│ RepartitionExec ││ DataSourceExec │
716-
24)│ ││ -------------------- │
717-
25)│ ││ files: 1 │
718-
26)│ ││ format: parquet │
719-
27)└─────────────┬─────────────┘└───────────────────────────┘
720-
28)┌─────────────┴─────────────┐
721-
29)│ DataSourceExec │
722-
30)│ -------------------- │
723-
31)│ files: 1 │
724-
32)│ format: csv │
725-
33)└───────────────────────────┘
713+
21)│ -------------------- ││ │
714+
22)│ CAST(table1.string_col AS ││ │
715+
23)│ Utf8View): ││ │
716+
24)│ CAST(string_col@1 AS ││ │
717+
25)│ Utf8View) ││ │
718+
26)│ ││ │
719+
27)│ bigint_col: ││ │
720+
28)│ bigint_col@2 ││ │
721+
29)│ ││ │
722+
30)│ date_col: date_col@3 ││ │
723+
31)│ int_col: int_col@0 ││ │
724+
32)│ ││ │
725+
33)│ string_col: ││ │
726+
34)│ string_col@1 ││ │
727+
35)└─────────────┬─────────────┘└─────────────┬─────────────┘
728+
36)┌─────────────┴─────────────┐┌─────────────┴─────────────┐
729+
37)│ RepartitionExec ││ DataSourceExec │
730+
38)│ ││ -------------------- │
731+
39)│ ││ files: 1 │
732+
40)│ ││ format: parquet │
733+
41)└─────────────┬─────────────┘└───────────────────────────┘
734+
42)┌─────────────┴─────────────┐
735+
43)│ DataSourceExec │
736+
44)│ -------------------- │
737+
45)│ files: 1 │
738+
46)│ format: csv │
739+
47)└───────────────────────────┘
726740

727741
# Query with outer hash join.
728742
query TT
@@ -755,19 +769,33 @@ physical_plan
755769
20)└─────────────┬─────────────┘└─────────────┬─────────────┘
756770
21)┌─────────────┴─────────────┐┌─────────────┴─────────────┐
757771
22)│ ProjectionExec ││ RepartitionExec │
758-
23)└─────────────┬─────────────┘└─────────────┬─────────────┘
759-
24)┌─────────────┴─────────────┐┌─────────────┴─────────────┐
760-
25)│ RepartitionExec ││ DataSourceExec │
761-
26)│ ││ -------------------- │
762-
27)│ ││ files: 1 │
763-
28)│ ││ format: parquet │
764-
29)└─────────────┬─────────────┘└───────────────────────────┘
765-
30)┌─────────────┴─────────────┐
766-
31)│ DataSourceExec │
767-
32)│ -------------------- │
768-
33)│ files: 1 │
769-
34)│ format: csv │
770-
35)└───────────────────────────┘
772+
23)│ -------------------- ││ │
773+
24)│ CAST(table1.string_col AS ││ │
774+
25)│ Utf8View): ││ │
775+
26)│ CAST(string_col@1 AS ││ │
776+
27)│ Utf8View) ││ │
777+
28)│ ││ │
778+
29)│ bigint_col: ││ │
779+
30)│ bigint_col@2 ││ │
780+
31)│ ││ │
781+
32)│ date_col: date_col@3 ││ │
782+
33)│ int_col: int_col@0 ││ │
783+
34)│ ││ │
784+
35)│ string_col: ││ │
785+
36)│ string_col@1 ││ │
786+
37)└─────────────┬─────────────┘└─────────────┬─────────────┘
787+
38)┌─────────────┴─────────────┐┌─────────────┴─────────────┐
788+
39)│ RepartitionExec ││ DataSourceExec │
789+
40)│ ││ -------------------- │
790+
41)│ ││ files: 1 │
791+
42)│ ││ format: parquet │
792+
43)└─────────────┬─────────────┘└───────────────────────────┘
793+
44)┌─────────────┴─────────────┐
794+
45)│ DataSourceExec │
795+
46)│ -------------------- │
796+
47)│ files: 1 │
797+
48)│ format: csv │
798+
49)└───────────────────────────┘
771799

772800

773801
# cleanup

0 commit comments

Comments
 (0)