From 1a06922ebfd9c83bbad8a1fadf284be6398bcd2e Mon Sep 17 00:00:00 2001 From: Guodong Jin Date: Wed, 18 Dec 2024 17:00:49 +0800 Subject: [PATCH] clean --- src/function/table/call/bm_info.cpp | 55 -------------------- src/include/common/serializer/deserializer.h | 2 - src/include/common/serializer/serializer.h | 4 -- 3 files changed, 61 deletions(-) delete mode 100644 src/function/table/call/bm_info.cpp diff --git a/src/function/table/call/bm_info.cpp b/src/function/table/call/bm_info.cpp deleted file mode 100644 index bc5219b08c9..00000000000 --- a/src/function/table/call/bm_info.cpp +++ /dev/null @@ -1,55 +0,0 @@ -#include "binder/binder.h" -#include "function/table/simple_table_functions.h" -#include "main/database.h" -#include "storage/buffer_manager/buffer_manager.h" -#include "storage/buffer_manager/memory_manager.h" - -namespace kuzu { -namespace function { - -struct BMInfoBindData final : SimpleTableFuncBindData { - uint64_t memLimit; - uint64_t memUsage; - - BMInfoBindData(uint64_t memLimit, uint64_t memUsage, binder::expression_vector columns) - : SimpleTableFuncBindData{std::move(columns), 1}, memLimit{memLimit}, memUsage{memUsage} {} - - std::unique_ptr copy() const override { - return std::make_unique(memLimit, memUsage, columns); - } -}; - -static common::offset_t tableFunc(TableFuncInput& input, TableFuncOutput& output) { - KU_ASSERT(output.dataChunk.getNumValueVectors() == 2); - const auto sharedState = input.sharedState->ptrCast(); - const auto morsel = sharedState->getMorsel(); - if (!morsel.hasMoreToOutput()) { - return 0; - } - const auto bindData = input.bindData->constPtrCast(); - output.dataChunk.getValueVectorMutable(0).setValue(0, bindData->memLimit); - output.dataChunk.getValueVectorMutable(1).setValue(0, bindData->memUsage); - return 1; -} - -static std::unique_ptr bindFunc(main::ClientContext* context, - TableFuncBindInput* input) { - auto memLimit = context->getMemoryManager()->getBufferManager()->getMemoryLimit(); - auto memUsage = context->getMemoryManager()->getBufferManager()->getUsedMemory(); - std::vector returnTypes; - returnTypes.emplace_back(common::LogicalType::UINT64()); - returnTypes.emplace_back(common::LogicalType::UINT64()); - auto returnColumnNames = std::vector{"mem_limit", "mem_usage"}; - auto columns = input->binder->createVariables(returnColumnNames, returnTypes); - return std::make_unique(memLimit, memUsage, columns); -} - -function_set BMInfoFunction::getFunctionSet() { - function_set functionSet; - functionSet.push_back(std::make_unique(name, tableFunc, bindFunc, - initSharedState, initEmptyLocalState, std::vector{})); - return functionSet; -} - -} // namespace function -} // namespace kuzu diff --git a/src/include/common/serializer/deserializer.h b/src/include/common/serializer/deserializer.h index f89a2592393..524982be788 100644 --- a/src/include/common/serializer/deserializer.h +++ b/src/include/common/serializer/deserializer.h @@ -110,8 +110,6 @@ class Deserializer { } } - void deserializeCaseInsensitiveSet(common::case_insensitve_set_t& values); - private: std::unique_ptr reader; }; diff --git a/src/include/common/serializer/serializer.h b/src/include/common/serializer/serializer.h index a9269552d59..bf17b881552 100644 --- a/src/include/common/serializer/serializer.h +++ b/src/include/common/serializer/serializer.h @@ -3,11 +3,9 @@ #include #include #include -#include #include #include -#include "common/case_insensitive_map.h" #include "common/serializer/writer.h" namespace kuzu { @@ -95,8 +93,6 @@ class Serializer { } } - void serializeCaseInsensitiveSet(const common::case_insensitve_set_t& values); - private: std::shared_ptr writer; };