[fix][serial] Support selection for v2 schema

dingodb · Feb 25, 2025 · 44fe12e · 44fe12e
1 parent e075712
commit 44fe12e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/coprocessor/coprocessor_v2.cc b/src/coprocessor/coprocessor_v2.cc
@@ -719,11 +719,13 @@ void CoprocessorV2::GetOriginalColumnIndexes() {
 
 void CoprocessorV2::GetSelectionColumnIndexes() {
   if (!coprocessor_.selection_columns().empty()) {
+    int n = 0;
     for (const auto& index : coprocessor_.selection_columns()) {
       int i = index;
-      DINGO_LOG(DEBUG) << "index:" << i;
+      DINGO_LOG(DEBUG) << "selection index:" << i;
       selection_column_indexes_.push_back(original_column_indexes_[i]);
-      selection_column_indexes_serial_[original_column_indexes_[i]] = i;
+      selection_column_indexes_serial_[original_column_indexes_[i]] = n;
+      n++;
     }
   } else {
     DINGO_LOG(DEBUG) << "selection_columns empty()";

diff --git a/src/serial b/src/serial
+5 −4		src/serial/record/V2/record_decoder.cc
+1 −0		src/serial/schema/V2/base_schema.h
+11 −0		src/serial/schema/V2/boolean_list_schema.cc
+1 −0		src/serial/schema/V2/boolean_list_schema.h
+4 −0		src/serial/schema/V2/boolean_schema.cc
+1 −0		src/serial/schema/V2/boolean_schema.h
+1 −0		src/serial/schema/V2/dingo_schema.h
+52 −0		src/serial/schema/V2/double_list_schema.cc
+2 −0		src/serial/schema/V2/double_list_schema.h
+21 −0		src/serial/schema/V2/double_schema.cc
+2 −0		src/serial/schema/V2/double_schema.h
+40 −0		src/serial/schema/V2/float_list_schema.cc
+2 −0		src/serial/schema/V2/float_list_schema.h
+22 −0		src/serial/schema/V2/float_schema.cc
+2 −0		src/serial/schema/V2/float_schema.h
+30 −0		src/serial/schema/V2/integer_list_schema.cc
+2 −0		src/serial/schema/V2/integer_list_schema.h
+9 −0		src/serial/schema/V2/integer_schema.cc
+2 −0		src/serial/schema/V2/integer_schema.h
+36 −0		src/serial/schema/V2/long_list_schema.cc
+2 −0		src/serial/schema/V2/long_list_schema.h
+9 −0		src/serial/schema/V2/long_schema.cc
+2 −0		src/serial/schema/V2/long_schema.h
+23 −0		src/serial/schema/V2/string_list_schema.cc
+4 −0		src/serial/schema/V2/string_list_schema.h
+18 −0		src/serial/schema/V2/string_schema.cc
+2 −0		src/serial/schema/V2/string_schema.h