From 75ddd01e7bac1f4b9bc21544de2c16bbd63d325b Mon Sep 17 00:00:00 2001 From: Liang-Chi Hsieh Date: Wed, 15 May 2024 22:51:22 -0700 Subject: [PATCH] Make swap_hash_join public API --- datafusion/core/src/physical_optimizer/join_selection.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/datafusion/core/src/physical_optimizer/join_selection.rs b/datafusion/core/src/physical_optimizer/join_selection.rs index 135a59aa0353..1613e5089860 100644 --- a/datafusion/core/src/physical_optimizer/join_selection.rs +++ b/datafusion/core/src/physical_optimizer/join_selection.rs @@ -157,7 +157,9 @@ fn swap_join_projection( } /// This function swaps the inputs of the given join operator. -fn swap_hash_join( +/// This function is public so other downstream projects can use it +/// to construct `HashJoinExec` with right side as the build side. +pub fn swap_hash_join( hash_join: &HashJoinExec, partition_mode: PartitionMode, ) -> Result> {