update query

apache · Sep 21, 2020 · 7e5e0be · 7e5e0be
1 parent a4bd3df
commit 7e5e0be
Show file tree

Hide file tree

Showing 2 changed files with 24 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)) {

diff --git a/...lt/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDeltaAndInvertedIndex.java b/...lt/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDeltaAndInvertedIndex.java
@@ -41,6 +41,8 @@ public class ColumnarVectorWrapperDirectWithDeleteDeltaAndInvertedIndex
 
   private BitSet nullBits;
 
+  private int counter;
+
   /**
    * Constructor
    * @param vectorWrapper vector to be filled
@@ -78,6 +80,17 @@ public void putNull(int rowId) {
     }
   }
 
+  @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 putAllByteArray(byte[] data, int offset, int length) {
     carbonColumnVector.putAllByteArray(data, offset, length);