Skip to content

Commit ad2b1dc

Browse files
authored
Make swap_hash_join public API (#10702)
1 parent c775e4d commit ad2b1dc

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

datafusion/core/src/physical_optimizer/join_selection.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -157,7 +157,9 @@ fn swap_join_projection(
157157
}
158158

159159
/// This function swaps the inputs of the given join operator.
160-
fn swap_hash_join(
160+
/// This function is public so other downstream projects can use it
161+
/// to construct `HashJoinExec` with right side as the build side.
162+
pub fn swap_hash_join(
161163
hash_join: &HashJoinExec,
162164
partition_mode: PartitionMode,
163165
) -> Result<Arc<dyn ExecutionPlan>> {

0 commit comments

Comments
 (0)