partial impl

korowa · Oct 10, 2023 · 7ca5706 · 7ca5706
1 parent 261b900
commit 7ca5706
Show file tree

Hide file tree

Showing 7 changed files with 324 additions and 31 deletions.
diff --git a/datafusion/core/src/physical_optimizer/enforce_distribution.rs b/datafusion/core/src/physical_optimizer/enforce_distribution.rs
@@ -365,6 +365,7 @@ fn adjust_input_keys_ordering(
                     left.clone(),
                     right.clone(),
                     new_conditions.0,
+                    None,
                     *join_type,
                     new_conditions.1,
                     *null_equals_null,
@@ -714,6 +715,7 @@ pub(crate) fn reorder_join_keys_to_inputs(
         left,
         right,
         on,
+        filter: None,
         join_type,
         sort_options,
         null_equals_null,
@@ -744,6 +746,7 @@ pub(crate) fn reorder_join_keys_to_inputs(
                     left.clone(),
                     right.clone(),
                     new_join_on,
+                    None,
                     *join_type,
                     new_sort_options,
                     *null_equals_null,
@@ -2004,6 +2007,7 @@ mod tests {
                 left,
                 right,
                 join_on.clone(),
+                None,
                 *join_type,
                 vec![SortOptions::default(); join_on.len()],
                 false,

diff --git a/datafusion/core/src/physical_optimizer/test_utils.rs b/datafusion/core/src/physical_optimizer/test_utils.rs
@@ -167,6 +167,7 @@ pub fn sort_merge_join_exec(
             left,
             right,
             join_on.clone(),
+            None,
             *join_type,
             vec![SortOptions::default(); join_on.len()],
             false,
-Original file line number
+Diff line change
@@ Expand Up / @@ -167,6 +167,7 @@ pub fn sort_merge_join_exec( @@
                 left,
                 right,
                 join_on.clone(),
+                None,
                 *join_type,
                 vec![SortOptions::default(); join_on.len()],
                 false,
@@ Expand Down @@