Github user ajantha-bhat commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2816#discussion_r228932987
--- Diff:
store/sdk/src/main/java/org/apache/carbondata/sdk/file/CarbonReader.java ---
@@ -90,6 +93,20 @@ public T readNextRow() throws IOException,
InterruptedException {
return currentReader.getCurrentValue();
}
+ /**
+ * Read and return next batch row objects
+ */
+ public Object[] readNextBatchRow() throws Exception {
+ validateReader();
+ int batch = Integer.parseInt(CarbonProperties.getInstance()
--- End diff --
What is this property is not set ? we get NPE here
---