Github user xubo245 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2792#discussion_r223244987
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/readsupport/impl/DictionaryDecodeReadSupport.java
---
@@ -81,7 +82,24 @@
data[i] = dictionaries[i].getDictionaryValueForKey((int) data[i]);
}
}
- return (T)data;
+ return (T) data;
+ }
+
+ /**
+ * get carbonRow, including data and datatpes
+ *
+ * @param data row data
+ * @return CarbonRow Object
+ */
+ public T readCarbonRow(Object[] data) {
--- End diff --
I add Row class and optimized readCarbonRow method
---