| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you 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 <cstddef> |
| #include <cstdint> |
| #include <functional> |
| #include <map> |
| #include <set> |
| #include <unordered_map> |
| #include <unordered_set> |
| #include <utility> |
| #include <vector> |
| |
| #include "paimon/result.h" |
| #include "paimon/traits.h" |
| namespace paimon { |
| /// Utils for objects. |
| class ObjectUtils { |
| public: |
| ObjectUtils() = delete; |
| ~ObjectUtils() = delete; |
| |
| template <typename T, typename U> |
| static bool ContainsAll(const T& all, const U& contains) { |
| using V = typename T::value_type; |
| std::unordered_set<V> all_set(all.begin(), all.end()); |
| for (const auto& element : contains) { |
| if (all_set.find(element) == all_set.end()) { |
| return false; |
| } |
| } |
| return true; |
| } |
| |
| template <typename T> |
| static bool Contains(const std::vector<T>& all, const T& target) { |
| for (const auto& v : all) { |
| if (v == target) { |
| return true; |
| } |
| } |
| return false; |
| } |
| |
| template <typename T> |
| static std::unordered_set<T> DuplicateItems(const std::vector<T>& entries) { |
| std::unordered_map<T, int32_t> counts; |
| for (const auto& entry : entries) { |
| counts[entry]++; |
| } |
| |
| std::unordered_set<T> duplicates; |
| for (const auto& entry : counts) { |
| if (entry.second > 1) { |
| duplicates.insert(entry.first); |
| } |
| } |
| return duplicates; |
| } |
| |
| template <typename T> |
| static bool TEST_Equal(const std::vector<T>& lhs, const std::vector<T>& rhs) { |
| if (lhs.size() != rhs.size()) { |
| return false; |
| } |
| for (size_t i = 0; i < lhs.size(); i++) { |
| if constexpr (is_pointer<T>::value) { |
| if (!lhs[i]->TEST_Equal(*rhs[i])) { |
| return false; |
| } |
| } else { |
| if (!lhs[i].TEST_Equal(rhs[i])) { |
| return false; |
| } |
| } |
| } |
| return true; |
| } |
| |
| template <typename T> |
| static bool Equal(const std::vector<T>& lhs, const std::vector<T>& rhs) { |
| if (lhs.size() != rhs.size()) { |
| return false; |
| } |
| for (size_t i = 0; i < lhs.size(); i++) { |
| if constexpr (is_pointer<T>::value) { |
| if (!(*(lhs[i]) == *(rhs[i]))) { |
| return false; |
| } |
| } else { |
| if (!(lhs[i] == rhs[i])) { |
| return false; |
| } |
| } |
| } |
| return true; |
| } |
| |
| // used to create an identifier to index map, param func is used to convert T to identifier I |
| // e.g., T = DataField, I = std::string, return std::map<std::string, int32_t> |
| template <typename T, typename Func> |
| static auto CreateIdentifierToIndexMap(const std::vector<T>& vec, const Func& func) |
| -> std::map<decltype(func(std::declval<T>())), int32_t> { |
| using KeyType = decltype(func(std::declval<T>())); |
| std::map<KeyType, int32_t> result; |
| for (int32_t i = 0; i < static_cast<int32_t>(vec.size()); ++i) { |
| result[func(vec[i])] = i; |
| } |
| return result; |
| } |
| |
| template <typename T> |
| static std::map<T, int32_t> CreateIdentifierToIndexMap(const std::vector<T>& vec) { |
| std::map<T, int32_t> index_map; |
| for (int32_t i = 0; i < static_cast<int32_t>(vec.size()); i++) { |
| index_map[vec[i]] = i; |
| } |
| return index_map; |
| } |
| |
| /// Precondition: U and T must be pointer and U::value can move to T::value |
| template <typename T, typename U> |
| static std::vector<T> MoveVector(std::vector<U>&& input) { |
| static_assert(is_pointer<U>::value && is_pointer<T>::value && |
| std::is_convertible_v<value_type_traits_t<U>, value_type_traits_t<T>>, |
| "U and T must be pointer and U::value can move to T::value"); |
| std::vector<T> result; |
| result.reserve(input.size()); |
| for (auto& item : input) { |
| result.push_back(std::move(item)); |
| } |
| input.clear(); |
| return result; |
| } |
| }; |
| } // namespace paimon |