From 7e5e0be1b2f2af6ea0397f2fcd1f695649a8f40c Mon Sep 17 00:00:00 2001
From: akkio-97 <akshay.nuthala@gmail.com>
Date: Mon, 21 Sep 2020 14:41:07 +0530
Subject: [PATCH] update query

---
 .../ColumnarVectorWrapperDirectWithDeleteDelta.java | 11 +++++++++++
 ...rapperDirectWithDeleteDeltaAndInvertedIndex.java | 13 +++++++++++++
 2 files changed, 24 insertions(+)

diff --git a/core/src/main/java/org/apache/carbondata/core/scan/result/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDelta.java b/core/src/main/java/org/apache/carbondata/core/scan/result/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDelta.java
index 30efbb0424c..b3111c82ea0 100644
--- a/core/src/main/java/org/apache/carbondata/core/scan/result/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDelta.java
+++ b/core/src/main/java/org/apache/carbondata/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/core/src/main/java/org/apache/carbondata/core/scan/result/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDeltaAndInvertedIndex.java b/core/src/main/java/org/apache/carbondata/core/scan/result/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDeltaAndInvertedIndex.java
index a5d7562d0c5..3a07b615de1 100644
--- a/core/src/main/java/org/apache/carbondata/core/scan/result/vector/impl/directread/ColumnarVectorWrapperDirectWithDeleteDeltaAndInvertedIndex.java
+++ b/core/src/main/java/org/apache/carbondata/core/scan/result/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);