Github user xubo245 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2816#discussion_r228392301
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonRecordReader.java ---
@@ -116,6 +116,20 @@ public void initialize(InputSplit inputSplit,
TaskAttemptContext context)
return readSupport.readRow(carbonIterator.next());
}
+ /**
+ * get batch result
+ *
+ * @param batch batch size
+ * @return rows
+ */
+ public List<Object[]> getBatchValue(int batch) {
+ rowCount += batch;
--- End diff --
ok, optimized
---