update

src/function/vector_blob_operations.cpp

@@ -2,7 +2,7 @@
 
 #include "function/blob/operations/decode_operation.h"
 #include "function/blob/operations/encode_operation.h"
-#include "function/string/operations/length_operation.h"
+#include "function/blob/operations/octet_length_operation.h"
 #include "function/string/vector_string_operations.h"
 
 namespace kuzu {
@@ -13,7 +13,7 @@ vector_operation_definitions OctetLengthVectorOperations::getDefinitions() {
     definitions.push_back(make_unique<VectorOperationDefinition>(common::OCTET_LENGTH_FUNC_NAME,
         std::vector<common::LogicalTypeID>{common::LogicalTypeID::BLOB},
         common::LogicalTypeID::INT64,
-        UnaryExecFunction<common::ku_string_t, int64_t, operation::Length>, nullptr, nullptr,
+        UnaryExecFunction<common::blob_t, int64_t, operation::OctetLength>, nullptr, nullptr,
         nullptr, false /* isVarLength */));
     return definitions;
 }

src/include/function/blob/operations/decode_operation.h

@@ -1,8 +1,5 @@
 #pragma once
 
-#include <cassert>
-#include <cstring>
-
 #include "common/types/blob.h"
 #include "utf8proc_wrapper.h"
 

src/include/function/blob/operations/encode_operation.h

@@ -1,8 +1,5 @@
 #pragma once
 
-#include <cassert>
-#include <cstring>
-
 #include "common/types/blob.h"
 
 namespace kuzu {

src/include/function/blob/operations/octet_length_operation.h

@@ -0,0 +1,17 @@
+#pragma once
+
+#include "common/types/blob.h"
+
+namespace kuzu {
+namespace function {
+namespace operation {
+
+struct OctetLength {
+    static inline void operation(common::blob_t& input, int64_t& result) {
+        result = input.value.len;
+    }
+};
+
+} // namespace operation
+} // namespace function
+} // namespace kuzu