| 180 | } |
| 181 | |
| 182 | private BatchIterator<Row> bufferedRowOrNone(int idx) { |
| 183 | if (idx < 0 || (cursorPosition >= rows.size() && exhausted)) { |
| 184 | return InMemoryBatchIterator.empty(SentinelRow.SENTINEL); |
| 185 | } else { |
| 186 | Object[] cells = rows.get(idx); |
| 187 | sharedRow.cells(cells); |
| 188 | return InMemoryBatchIterator.of(sharedRow, SentinelRow.SENTINEL); |
| 189 | } |
| 190 | } |
| 191 | |
| 192 | private void triggerConsumer(RowConsumer consumer, BatchIterator<Row> fullResult, ScrollMode mode, long lCount) { |
| 193 | // Long.MAX_VALUE is used as "ALL" |