(&self)
| 799 | } |
| 800 | |
| 801 | fn left_right(&self) -> (Arc<DataSourceExec>, Arc<DataSourceExec>) { |
| 802 | let schema1 = self.input1[0].schema(); |
| 803 | let schema2 = self.input2[0].schema(); |
| 804 | let left = MemorySourceConfig::try_new_exec( |
| 805 | std::slice::from_ref(&self.input1), |
| 806 | schema1, |
| 807 | None, |
| 808 | ) |
| 809 | .unwrap(); |
| 810 | let right = MemorySourceConfig::try_new_exec( |
| 811 | std::slice::from_ref(&self.input2), |
| 812 | schema2, |
| 813 | None, |
| 814 | ) |
| 815 | .unwrap(); |
| 816 | (left, right) |
| 817 | } |
| 818 | |
| 819 | fn join_filter(&self) -> Option<JoinFilter> { |
| 820 | let schema1 = self.input1[0].schema(); |
no test coverage detected