Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1606#discussion_r154999525
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/loading/sort/unsafe/holder/UnsafeSortTempFileChunkHolder.java
---
@@ -352,6 +330,49 @@ private void fillDataForPrefetch() {
}
}
+ private Object[][] getBatchedRowFromStream(int expected) throws
CarbonSortKeyAndGroupByException {
--- End diff --
please add comment for this function---
