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
---