We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 81c6d77 commit 72d9f20Copy full SHA for 72d9f20
common/src/main/java/com/robin/core/fileaccess/iterator/AbstractFileIterator.java
@@ -255,7 +255,7 @@ public boolean hasNext() {
255
try {
256
// no order by
257
if(!useOrderBy && !useGroupBy) {
258
- groupOrderByInit();
+
259
pullNext();
260
while (!CollectionUtils.isEmpty(cachedValue) && useFilter && !CommRecordGenerator.doesRecordAcceptable(segment, cachedValue)) {
261
@@ -267,6 +267,9 @@ public boolean hasNext() {
267
return !CollectionUtils.isEmpty(cachedValue);
268
}else{
269
//capture all record to offHeap
270
+ if(CollectionUtils.isEmpty(groupByMap)) {
271
+ groupOrderByInit();
272
+ }
273
newRecord.clear();
274
if(groupIter.hasNext()) {
275
0 commit comments