From d1d1a65ce4be96b335932bb370fa34fe4f310479 Mon Sep 17 00:00:00 2001 From: akkio-97 Date: Mon, 21 Sep 2020 14:41:07 +0530 Subject: [PATCH] update query --- .../ColumnarVectorWrapperDirectWithDeleteDelta.java | 11 +++++++++++ 1 file changed, 11 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)) {