Skip to content

Commit 2c9f42b

Browse files
authored
feat: Support SortMergeJoin proto serde (#17296)
* Implement ser/de part of SortMergeJoin * add round trip tests for sort merge join * add filter test to roundtrip
1 parent 4925e6c commit 2c9f42b

5 files changed

Lines changed: 540 additions & 5 deletions

File tree

datafusion/proto/proto/datafusion.proto

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -729,6 +729,7 @@ message PhysicalPlanNode {
729729
JsonScanExecNode json_scan = 31;
730730
CooperativeExecNode cooperative = 32;
731731
GenerateSeriesNode generate_series = 33;
732+
SortMergeJoinExecNode sort_merge_join = 34;
732733
}
733734
}
734735

@@ -1343,3 +1344,13 @@ message GenerateSeriesNode {
13431344
GenerateSeriesArgsDate date_args = 6;
13441345
}
13451346
}
1347+
1348+
message SortMergeJoinExecNode {
1349+
PhysicalPlanNode left = 1;
1350+
PhysicalPlanNode right = 2;
1351+
repeated JoinOn on = 3;
1352+
datafusion_common.JoinType join_type = 4;
1353+
JoinFilter filter = 5;
1354+
repeated SortExprNode sort_options = 6;
1355+
datafusion_common.NullEquality null_equality = 7;
1356+
}

datafusion/proto/src/generated/pbjson.rs

Lines changed: 214 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

datafusion/proto/src/generated/prost.rs

Lines changed: 20 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)