(&self)
| 841 | } |
| 842 | |
| 843 | fn hash_join(&self) -> Arc<HashJoinExec> { |
| 844 | let (left, right) = self.left_right(); |
| 845 | Arc::new( |
| 846 | HashJoinExec::try_new( |
| 847 | left, |
| 848 | right, |
| 849 | self.on_columns().clone(), |
| 850 | self.join_filter(), |
| 851 | &self.join_type, |
| 852 | None, |
| 853 | PartitionMode::Partitioned, |
| 854 | NullEquality::NullEqualsNothing, |
| 855 | false, |
| 856 | ) |
| 857 | .unwrap(), |
| 858 | ) |
| 859 | } |
| 860 | |
| 861 | fn nested_loop_join(&self) -> Arc<NestedLoopJoinExec> { |
| 862 | let (left, right) = self.left_right(); |
no test coverage detected