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

simplify chained sequence operations

This commit is contained in:
Xavier Léauté 2014-05-16 13:49:40 -07:00
parent 07b2a0efa6
commit 3223d46c1a
2 changed files with 21 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
processing/src/main/java/io/druid/query/QueryRunnerHelper.java
View File

@ -59,7 +59,7 @@ public class QueryRunnerHelper
List<Interval> queryIntervals,
Filter filter,
QueryGranularity granularity,
Function<Cursor, Result<T>> mapFn
final Function<Cursor, Result<T>> mapFn
)
{
Preconditions.checkArgument(
@ -68,20 +68,16 @@ public class QueryRunnerHelper
return Sequences.filter(
Sequences.map(
Sequences.map(
adapter.makeCursors(filter, queryIntervals.get(0), granularity),
new Function<Cursor, Cursor>()
{
@Override
public Cursor apply(@Nullable Cursor input)
{
log.debug("Running over cursor[%s]", adapter.getInterval(), input.getTime());
return input;
}
}
),
mapFn
adapter.makeCursors(filter, queryIntervals.get(0), granularity),
new Function<Cursor, Result<T>>()
{
@Override
public Result<T> apply(@Nullable Cursor input)
{
log.debug("Running over cursor[%s]", adapter.getInterval(), input.getTime());
return mapFn.apply(input);
}
}
),
Predicates.<Result<T>>notNull()
);

23
processing/src/main/java/io/druid/query/topn/TopNQueryEngine.java
View File

@ -74,19 +74,16 @@ public class TopNQueryEngine
return Sequences.filter(
Sequences.map(
Sequences.map(
adapter.makeCursors(filter, queryIntervals.get(0), granularity),
new Function<Cursor, Cursor>()
{
@Override
public Cursor apply(Cursor input)
{
log.debug("Running over cursor[%s]", adapter.getInterval(), input.getTime());
return input;
}
}
),
mapFn
adapter.makeCursors(filter, queryIntervals.get(0), granularity),
new Function<Cursor, Result<TopNResultValue>>()
{
@Override
public Result<TopNResultValue> apply(Cursor input)
{
log.debug("Running over cursor[%s]", adapter.getInterval(), input.getTime());
return mapFn.apply(input);
}
}
),
Predicates.<Result<TopNResultValue>>notNull()
);