| 1 | //===----------------------------------------------------------------------===// |
|---|---|
| 2 | // DuckDB |
| 3 | // |
| 4 | // duckdb/planner/logical_operator.hpp |
| 5 | // |
| 6 | // |
| 7 | //===----------------------------------------------------------------------===// |
| 8 | |
| 9 | #pragma once |
| 10 | |
| 11 | #include "duckdb/catalog/catalog.hpp" |
| 12 | #include "duckdb/common/common.hpp" |
| 13 | #include "duckdb/common/enums/logical_operator_type.hpp" |
| 14 | #include "duckdb/optimizer/join_order/estimated_properties.hpp" |
| 15 | #include "duckdb/planner/column_binding.hpp" |
| 16 | #include "duckdb/planner/expression.hpp" |
| 17 | #include "duckdb/planner/logical_operator_visitor.hpp" |
| 18 | #include "duckdb/planner/plan_serialization.hpp" |
| 19 | |
| 20 | #include <algorithm> |
| 21 | #include <functional> |
| 22 | |
| 23 | namespace duckdb { |
| 24 | |
| 25 | class FieldWriter; |
| 26 | class FieldReader; |
| 27 | |
| 28 | //! The current version of the plan serialization format. Exposed via by @Serializer & @Deserializer |
| 29 | //! to be used by various Operator to know what format to read and write. |
| 30 | extern const uint64_t PLAN_SERIALIZATION_VERSION; |
| 31 | |
| 32 | //! LogicalOperator is the base class of the logical operators present in the |
| 33 | //! logical query tree |
| 34 | class LogicalOperator { |
| 35 | public: |
| 36 | explicit LogicalOperator(LogicalOperatorType type); |
| 37 | LogicalOperator(LogicalOperatorType type, vector<unique_ptr<Expression>> expressions); |
| 38 | virtual ~LogicalOperator(); |
| 39 | |
| 40 | //! The type of the logical operator |
| 41 | LogicalOperatorType type; |
| 42 | //! The set of children of the operator |
| 43 | vector<unique_ptr<LogicalOperator>> children; |
| 44 | //! The set of expressions contained within the operator, if any |
| 45 | vector<unique_ptr<Expression>> expressions; |
| 46 | //! The types returned by this logical operator. Set by calling LogicalOperator::ResolveTypes. |
| 47 | vector<LogicalType> types; |
| 48 | //! Estimated Cardinality |
| 49 | idx_t estimated_cardinality; |
| 50 | bool has_estimated_cardinality; |
| 51 | |
| 52 | unique_ptr<EstimatedProperties> estimated_props; |
| 53 | |
| 54 | public: |
| 55 | virtual vector<ColumnBinding> GetColumnBindings(); |
| 56 | static vector<ColumnBinding> GenerateColumnBindings(idx_t table_idx, idx_t column_count); |
| 57 | static vector<LogicalType> MapTypes(const vector<LogicalType> &types, const vector<idx_t> &projection_map); |
| 58 | static vector<ColumnBinding> MapBindings(const vector<ColumnBinding> &types, const vector<idx_t> &projection_map); |
| 59 | |
| 60 | //! Resolve the types of the logical operator and its children |
| 61 | void ResolveOperatorTypes(); |
| 62 | |
| 63 | virtual string GetName() const; |
| 64 | virtual string ParamsToString() const; |
| 65 | virtual string ToString() const; |
| 66 | DUCKDB_API void Print(); |
| 67 | //! Debug method: verify that the integrity of expressions & child nodes are maintained |
| 68 | virtual void Verify(ClientContext &context); |
| 69 | |
| 70 | void AddChild(unique_ptr<LogicalOperator> child); |
| 71 | virtual idx_t EstimateCardinality(ClientContext &context); |
| 72 | |
| 73 | //! Serializes a LogicalOperator to a stand-alone binary blob |
| 74 | void Serialize(Serializer &serializer) const; |
| 75 | //! Serializes an LogicalOperator to a stand-alone binary blob |
| 76 | virtual void Serialize(FieldWriter &writer) const = 0; |
| 77 | |
| 78 | static unique_ptr<LogicalOperator> Deserialize(Deserializer &deserializer, PlanDeserializationState &state); |
| 79 | |
| 80 | virtual unique_ptr<LogicalOperator> Copy(ClientContext &context) const; |
| 81 | |
| 82 | virtual bool RequireOptimizer() const { |
| 83 | return true; |
| 84 | } |
| 85 | |
| 86 | //! Allows LogicalOperators to opt out of serialization |
| 87 | virtual bool SupportSerialization() const { |
| 88 | return true; |
| 89 | }; |
| 90 | |
| 91 | //! Returns the set of table indexes of this operator |
| 92 | virtual vector<idx_t> GetTableIndex() const; |
| 93 | |
| 94 | protected: |
| 95 | //! Resolve types for this specific operator |
| 96 | virtual void ResolveTypes() = 0; |
| 97 | |
| 98 | public: |
| 99 | template <class TARGET> |
| 100 | TARGET &Cast() { |
| 101 | if (TARGET::TYPE != LogicalOperatorType::LOGICAL_INVALID && type != TARGET::TYPE) { |
| 102 | throw InternalException("Failed to cast logical operator to type - logical operator type mismatch"); |
| 103 | } |
| 104 | return reinterpret_cast<TARGET &>(*this); |
| 105 | } |
| 106 | |
| 107 | template <class TARGET> |
| 108 | const TARGET &Cast() const { |
| 109 | if (TARGET::TYPE != LogicalOperatorType::LOGICAL_INVALID && type != TARGET::TYPE) { |
| 110 | throw InternalException("Failed to cast logical operator to type - logical operator type mismatch"); |
| 111 | } |
| 112 | return reinterpret_cast<const TARGET &>(*this); |
| 113 | } |
| 114 | }; |
| 115 | } // namespace duckdb |
| 116 |