// Copyright (C) 2019-2020 Zilliz. All rights reserved. // // Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance // with the License. You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software distributed under the License // is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express // or implied. See the License for the specific language governing permissions and limitations under the License #pragma once #include #include #include #include #include #include "Plan.h" #include "PlanNode.h" #include "exceptions/EasyAssert.h" #include "utils/Json.h" #include "common/Consts.h" namespace milvus::query { using Json = nlohmann::json; struct ExtractedPlanInfo { public: explicit ExtractedPlanInfo(int64_t size) : involved_fields_(size) { } void add_involved_field(FieldId field_id) { auto pos = field_id.get() - START_USER_FIELDID; AssertInfo(pos >= 0, "invalid field id"); involved_fields_.set(pos); } public: BitsetType involved_fields_; }; struct Plan { public: explicit Plan(const Schema& schema) : schema_(schema) { } public: const Schema& schema_; std::unique_ptr plan_node_; std::map tag2field_; // PlaceholderName -> FieldId std::vector target_entries_; void check_identical(Plan& other); public: std::optional extra_info_opt_; // TODO: add move extra info }; struct Placeholder { std::string tag_; int64_t num_of_queries_; int64_t line_sizeof_; aligned_vector blob_; template const T* get_blob() const { return reinterpret_cast(blob_.data()); } template T* get_blob() { return reinterpret_cast(blob_.data()); } }; struct RetrievePlan { public: explicit RetrievePlan(const Schema& schema) : schema_(schema) { } public: const Schema& schema_; std::unique_ptr plan_node_; std::vector field_ids_; }; using PlanPtr = std::unique_ptr; struct PlaceholderGroup : std::vector { using std::vector::vector; }; } // namespace milvus::query