Skip to content

Commit f1a5ffd

Browse files
LiuRuoyu01rock-git
authored andcommitted
[fix][store] Scalar only support coprocessor v1
1 parent c75a86a commit f1a5ffd

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

src/coprocessor/coprocessor_scalar.cc

+1-1
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ butil::Status CoprocessorScalar::Filter(const pb::common::VectorScalardata& scal
103103

104104
std::unique_ptr<std::vector<expr::Operand>> result_operand_ptr;
105105

106-
status = DoRelExprCore(0x02, original_record, result_operand_ptr);
106+
status = DoRelExprCore(default_scalar_codec_version_, original_record, result_operand_ptr);
107107
if (!status.ok()) {
108108
DINGO_LOG(ERROR) << status.error_cstr();
109109
return status;

src/coprocessor/coprocessor_scalar.h

+2
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
#include <serial/schema/base_schema.h>
1919

2020
#include <any>
21+
#include <cstdint>
2122
#include <vector>
2223

2324
#include "butil/status.h"
@@ -59,6 +60,7 @@ class CoprocessorScalar : public CoprocessorV2 {
5960
static bvar::Adder<uint64_t> bvar_coprocessor_v2_filter_scalar_running_num;
6061
static bvar::Adder<uint64_t> bvar_coprocessor_v2_filter_scalar_total_num;
6162
static bvar::LatencyRecorder coprocessor_v2_filter_scalar_latency;
63+
const int default_scalar_codec_version_{1};
6264
};
6365

6466
} // namespace dingodb

0 commit comments

Comments
 (0)