ElasticQueryBuilder: Use Java 8's Instant instead of Joda's DateTime

Change-Id: Id9ca23d6ea0ab3c81e54e5f5c98dbc9b2f524471
This commit is contained in:
David Pursehouse 2016-11-15 14:10:58 -08:00
parent 01d42968a5
commit e9340012e6

View File

@ -31,7 +31,8 @@ import org.apache.lucene.search.BooleanQuery;
import org.elasticsearch.index.query.BoolQueryBuilder; import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.index.query.QueryBuilders;
import org.joda.time.DateTime;
import java.time.Instant;
public class ElasticQueryBuilder { public class ElasticQueryBuilder {
@ -138,7 +139,7 @@ public class ElasticQueryBuilder {
throws QueryParseException { throws QueryParseException {
if (r.getMinTimestamp().getTime() == 0) { if (r.getMinTimestamp().getTime() == 0) {
return QueryBuilders.rangeQuery(r.getField().getName()) return QueryBuilders.rangeQuery(r.getField().getName())
.gt(new DateTime(r.getMaxTimestamp().getTime())); .gt(Instant.ofEpochMilli(r.getMaxTimestamp().getTime()));
} }
throw new QueryParseException("cannot negate: " + r); throw new QueryParseException("cannot negate: " + r);
} }
@ -150,11 +151,11 @@ public class ElasticQueryBuilder {
(TimestampRangePredicate<T>) p; (TimestampRangePredicate<T>) p;
if (p instanceof AfterPredicate) { if (p instanceof AfterPredicate) {
return QueryBuilders.rangeQuery(r.getField().getName()) return QueryBuilders.rangeQuery(r.getField().getName())
.gte(new DateTime(r.getMinTimestamp().getTime())); .gte(Instant.ofEpochMilli(r.getMinTimestamp().getTime()));
} }
return QueryBuilders.rangeQuery(r.getField().getName()) return QueryBuilders.rangeQuery(r.getField().getName())
.gte(new DateTime(r.getMinTimestamp().getTime())) .gte(Instant.ofEpochMilli(r.getMinTimestamp().getTime()))
.lte(new DateTime(r.getMaxTimestamp().getTime())); .lte(Instant.ofEpochMilli(r.getMaxTimestamp().getTime()));
} }
throw new QueryParseException("not a timestamp: " + p); throw new QueryParseException("not a timestamp: " + p);
} }