(&self)
| 859 | } |
| 860 | |
| 861 | fn nested_loop_join(&self) -> Arc<NestedLoopJoinExec> { |
| 862 | let (left, right) = self.left_right(); |
| 863 | |
| 864 | let column_indices = self.column_indices(); |
| 865 | let intermediate_schema = self.intermediate_schema(); |
| 866 | let expression = self.composite_filter_expression(); |
| 867 | |
| 868 | let filter = |
| 869 | JoinFilter::new(expression, column_indices, Arc::new(intermediate_schema)); |
| 870 | |
| 871 | Arc::new( |
| 872 | NestedLoopJoinExec::try_new(left, right, Some(filter), &self.join_type, None) |
| 873 | .unwrap(), |
| 874 | ) |
| 875 | } |
| 876 | |
| 877 | /// Perform joins tests on same inputs and verify outputs are equal |
| 878 | /// `join_tests` - identifies what join types to test |
no test coverage detected