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

rename t to now

This commit is contained in:
Xavier Léauté 2014-08-26 17:16:09 -07:00
parent eb7dd6dc74
commit e39b6975fa
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/io/druid/query/TimewarpOperator.java
View File

@ -75,19 +75,19 @@ public class TimewarpOperator<T> implements PostProcessingOperator<T>
return postProcess(baseQueryRunner, DateTime.now().getMillis()); return postProcess(baseQueryRunner, DateTime.now().getMillis());
} }
public QueryRunner<T> postProcess(final QueryRunner<T> baseRunner, final long t) public QueryRunner<T> postProcess(final QueryRunner<T> baseRunner, final long now)
{ {
return new QueryRunner<T>() return new QueryRunner<T>()
{ {
@Override @Override
public Sequence<T> run(Query<T> query) public Sequence<T> run(Query<T> query)
{ {
final long offset = computeOffset(t); final long offset = computeOffset(now);
final Interval interval = query.getIntervals().get(0); final Interval interval = query.getIntervals().get(0);
final Interval modifiedInterval = new Interval( final Interval modifiedInterval = new Interval(
interval.getStartMillis() + offset, interval.getStartMillis() + offset,
Math.min(interval.getEndMillis() + offset, t + offset) Math.min(interval.getEndMillis() + offset, now + offset)
); );
return Sequences.map( return Sequences.map(
baseRunner.run( baseRunner.run(
@ -106,7 +106,7 @@ public class TimewarpOperator<T> implements PostProcessingOperator<T>
value = new TimeBoundaryResultValue( value = new TimeBoundaryResultValue(
ImmutableMap.of( ImmutableMap.of(
TimeBoundaryQuery.MIN_TIME, boundary.getMinTime().minus(offset), TimeBoundaryQuery.MIN_TIME, boundary.getMinTime().minus(offset),
TimeBoundaryQuery.MAX_TIME, new DateTime(Math.min(boundary.getMaxTime().getMillis() - offset, t)) TimeBoundaryQuery.MAX_TIME, new DateTime(Math.min(boundary.getMaxTime().getMillis() - offset, now))
) )
); );
} }