Changed base class to PhysicalComparisonJoin so two children are allowed

cwida · Feb 27, 2024 · 2dd2996 · 2dd2996
1 parent 92536ff
commit 2dd2996
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/duckpgq/include/duckpgq/operators/physical_path_finding_operator.hpp b/duckpgq/include/duckpgq/operators/physical_path_finding_operator.hpp
@@ -8,11 +8,12 @@
 
 #pragma once
 
+#include "duckdb/execution/operator/join/physical_comparison_join.hpp"
 #include "duckdb/execution/physical_operator.hpp"
 #include "duckdb/planner/operator/logical_extension_operator.hpp"
 
 namespace duckdb {
-class PhysicalPathFinding : public CachingPhysicalOperator {
+class PhysicalPathFinding : public PhysicalComparisonJoin {
 public:
   static constexpr const PhysicalOperatorType TYPE =
       PhysicalOperatorType::EXTENSION;

diff --git a/duckpgq/src/duckpgq/operators/physical_path_finding_operator.cpp b/duckpgq/src/duckpgq/operators/physical_path_finding_operator.cpp
@@ -13,7 +13,7 @@ namespace duckdb {
 PhysicalPathFinding::PhysicalPathFinding(LogicalExtensionOperator &op,
                                          unique_ptr<PhysicalOperator> left,
                                          unique_ptr<PhysicalOperator> right)
-    : CachingPhysicalOperator(TYPE,  op.types, 0) {
+    : PhysicalComparisonJoin(op, TYPE, {}, JoinType::INNER, 0) {
   children.push_back(std::move(left));
   children.push_back(std::move(right));
 }