Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

improved doc

This commit is contained in:
Justin Borromeo 2019-02-11 10:37:11 -08:00
parent f0eddee665
commit ecb0f483a9
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
processing/src/main/java/org/apache/druid/query/scan/ScanQueryQueryToolChest.java
View File

@ -198,9 +198,9 @@ public class ScanQueryQueryToolChest extends QueryToolChest<ScanResultValue, Sca
} }
/** /**
* This iterator supports iteration through any Iterable and aggregates events in the Iterable into ScanResultValues * This iterator supports iteration through any Iterable of unbatched ScanResultValues (1 event/SRV) and aggregates
* with {int batchSize} events. The columns from the first event per ScanResultValue will be used to populate the * events into ScanResultValues with {int batchSize} events. The columns from the first event per ScanResultValue
* column section. * will be used to populate the column section.
*/ */
private static class ScanBatchedTimeOrderedIterator implements CloseableIterator<ScanResultValue> private static class ScanBatchedTimeOrderedIterator implements CloseableIterator<ScanResultValue>
{ {
@ -227,7 +227,7 @@ public class ScanQueryQueryToolChest extends QueryToolChest<ScanResultValue, Sca
@Override @Override
public ScanResultValue next() public ScanResultValue next()
{ {
// Create new scanresultvalue from event map // Create new ScanResultValue from event map
List<Object> eventsToAdd = new ArrayList<>(batchSize); List<Object> eventsToAdd = new ArrayList<>(batchSize);
List<String> columns = new ArrayList<>(); List<String> columns = new ArrayList<>();
while (eventsToAdd.size() < batchSize && itr.hasNext()) { while (eventsToAdd.size() < batchSize && itr.hasNext()) {