Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1581#discussion_r154838503
--- Diff:
integration/spark2/src/main/java/org/apache/carbondata/spark/vectorreader/ColumnarVectorWrapper.java
---
@@ -200,7 +205,7 @@ public ColumnarVectorWrapper(ColumnVector columnVector,
boolean[] filteredRows)
}
@Override public DataType getType() {
- return columnVector.dataType();
+ return
CarbonScalaUtil.convertSparkToCarbonDataType(columnVector.dataType());
--- End diff --
store the dataType as class variable, don't convert each time.
---