Github user kunal642 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2736#discussion_r219947411
--- Diff:
core/src/main/java/org/apache/carbondata/core/scan/executor/util/QueryUtil.java
---
@@ -781,4 +781,34 @@ public static void putDataToVector(CarbonColumnVector
vector, byte[] value, int
}
}
}
+
+ /**
+ * Put the data to vector
+ *
+ * @param vector
+ * @param value
+ * @param vectorRow
+ */
+ public static void putDataToVector(CarbonColumnVector vector, Object
value, int vectorRow) {
+ DataType dt = vector.getType();
+ if (value.equals(CarbonCommonConstants.MEMBER_DEFAULT_VAL_ARRAY) ||
value
+ .equals(CarbonCommonConstants.EMPTY_BYTE_ARRAY)) {
+ vector.putNull(vectorRow);
+ } else {
+ if (dt == DataTypes.STRING) {
+ vector.putBytes(vectorRow, (byte[]) value);
+ } else if (dt == DataTypes.BOOLEAN) {
+ vector.putBoolean(vectorRow, (boolean) value);
+ } else if (dt == DataTypes.SHORT) {
+ vector.putShort(vectorRow, (short) value);
+ } else if (dt == DataTypes.INT) {
+ vector.putInt(vectorRow, (int) value);
+ } else if (dt == DataTypes.LONG) {
--- End diff --
Please handle for byte also
---
