Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-25 04:16:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix offset and nulls

Browse Source
This commit is contained in:
Xavier Léauté 2014-08-28 17:35:26 -07:00
parent 9f742a87a6
commit 743a9bfdac
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
processing/src/main/java/io/druid/query/TimewarpOperator.java
View File

@ -109,10 +109,12 @@ public class TimewarpOperator<T> implements PostProcessingOperator<T>
minTime = boundary.getMinTime(); minTime = boundary.getMinTime();
} catch(IllegalArgumentException e) {} } catch(IllegalArgumentException e) {}
final DateTime maxTime = boundary.getMaxTime();
return (T) ((TimeBoundaryQuery) query).buildResult( return (T) ((TimeBoundaryQuery) query).buildResult(
timestamp, timestamp,
minTime, minTime != null ? minTime.minus(offset) : null,
boundary.getMaxTime() maxTime != null ? maxTime.minus(offset) : null
).iterator().next(); ).iterator().next();
} }
return (T) new Result(timestamp, value); return (T) new Result(timestamp, value);