update query

apache · Sep 21, 2020 · d1d1a65 · d1d1a65
1 parent a4bd3df
commit d1d1a65
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/...a/core/scan/result/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDelta.java b/...a/core/scan/result/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDelta.java
@@ -58,6 +58,17 @@ public void putBoolean(int rowId, boolean value) {
     }
   }
 
+  @Override
+  public void putObject(int rowId, Object obj) {
+    if (!deletedRows.get(rowId)) {
+      if (nullBits.get(rowId)) {
+        columnVector.putNull(counter++);
+      } else {
+        columnVector.putObject(counter++, obj);
+      }
+    }
+  }
+
   @Override
   public void putFloat(int rowId, float value) {
     if (!deletedRows.get(rowId)) {