1 | #include "duckdb/execution/operator/join/physical_comparison_join.hpp" |
---|---|
2 | |
3 | using namespace duckdb; |
4 | using namespace std; |
5 | |
6 | PhysicalComparisonJoin::PhysicalComparisonJoin(LogicalOperator &op, PhysicalOperatorType type, |
7 | vector<JoinCondition> conditions_, JoinType join_type) |
8 | : PhysicalJoin(op, type, join_type) { |
9 | conditions.resize(conditions_.size()); |
10 | // we reorder conditions so the ones with COMPARE_EQUAL occur first |
11 | idx_t equal_position = 0; |
12 | idx_t other_position = conditions_.size() - 1; |
13 | for (idx_t i = 0; i < conditions_.size(); i++) { |
14 | if (conditions_[i].comparison == ExpressionType::COMPARE_EQUAL) { |
15 | // COMPARE_EQUAL, move to the start |
16 | conditions[equal_position++] = std::move(conditions_[i]); |
17 | } else { |
18 | // other expression, move to the end |
19 | conditions[other_position--] = std::move(conditions_[i]); |
20 | } |
21 | } |
22 | } |
23 | |
24 | string PhysicalComparisonJoin::ExtraRenderInformation() const { |
25 | string extra_info = JoinTypeToString(type) + "\n"; |
26 | for (auto &it : conditions) { |
27 | string op = ExpressionTypeToOperator(it.comparison); |
28 | extra_info += it.left->GetName() + op + it.right->GetName() + "\n"; |
29 | } |
30 | return extra_info; |
31 | } |
32 |