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

Added more javadoc

This commit is contained in:
Justin Borromeo 2019-02-11 10:18:45 -08:00
parent 5f92dd7325
commit f0eddee665
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -100,19 +100,19 @@ public class ScanQueryQueryToolChest extends QueryToolChest<ScanResultValue, Sca
Iterator<ScanResultValue> scanResultIterator = scanQueryLimitRowIteratorMaker.make();
return new BaseSequence(
new BaseSequence.IteratorMaker<ScanResultValue, ScanBatchedTimeOrderedQueueIterator>()
new BaseSequence.IteratorMaker<ScanResultValue, ScanBatchedTimeOrderedIterator>()
{
@Override
public ScanBatchedTimeOrderedQueueIterator make()
public ScanBatchedTimeOrderedIterator make()
{
return new ScanBatchedTimeOrderedQueueIterator(
return new ScanBatchedTimeOrderedIterator(
sortScanResultValues(scanResultIterator, scanQuery),
scanQuery.getBatchSize()
);
}
@Override
public void cleanup(ScanBatchedTimeOrderedQueueIterator iterFromMake)
public void cleanup(ScanBatchedTimeOrderedIterator iterFromMake)
{
CloseQuietly.close(iterFromMake);
}
@ -197,12 +197,17 @@ public class ScanQueryQueryToolChest extends QueryToolChest<ScanResultValue, Sca
return sortedElements.iterator();
}
private static class ScanBatchedTimeOrderedQueueIterator implements CloseableIterator<ScanResultValue>
/**
* This iterator supports iteration through any Iterable and aggregates events in the Iterable into ScanResultValues
* with {int batchSize} events. The columns from the first event per ScanResultValue will be used to populate the
* column section.
*/
private static class ScanBatchedTimeOrderedIterator implements CloseableIterator<ScanResultValue>
{
private final Iterator<ScanResultValue> itr;
private final int batchSize;
public ScanBatchedTimeOrderedQueueIterator(Iterator<ScanResultValue> iterator, int batchSize)
public ScanBatchedTimeOrderedIterator(Iterator<ScanResultValue> iterator, int batchSize)
{
this.itr = iterator;
this.batchSize = batchSize;

4
processing/src/main/java/org/apache/druid/query/scan/ScanResultValueTimestampComparator.java
View File

@ -50,8 +50,8 @@ public class ScanResultValueTimestampComparator implements Comparator<ScanResult
int comparison;
if (scanQuery.getResultFormat().equals(ScanQuery.RESULT_FORMAT_LIST)) {
comparison = Longs.compare(
(Long) ((Map<String, Object>) ((List) o1.getEvents()).get(0)).get(ColumnHolder.TIME_COLUMN_NAME),
(Long) ((Map<String, Object>) ((List) o2.getEvents()).get(0)).get(ColumnHolder.TIME_COLUMN_NAME)
(Long) ((Map<String, Object>) ((List<Object>) o1.getEvents()).get(0)).get(ColumnHolder.TIME_COLUMN_NAME),
(Long) ((Map<String, Object>) ((List<Object>) o2.getEvents()).get(0)).get(ColumnHolder.TIME_COLUMN_NAME)
);
} else if (scanQuery.getResultFormat().equals(ScanQuery.RESULT_FORMAT_COMPACTED_LIST)) {
int val1TimeColumnIndex = o1.getColumns().indexOf(ColumnHolder.TIME_COLUMN_NAME);