diff options
author | Nicholas Knize <nknize@gmail.com> | 2016-02-10 15:29:34 -0600 |
---|---|---|
committer | Nicholas Knize <nknize@gmail.com> | 2016-02-11 14:28:50 -0600 |
commit | 52ee4c70275a6b54ac193f5a13e185355dc962bc (patch) | |
tree | 58d4b73e307ee24c69dc73212b2d1ed13113176d /core/src/main/java/org/elasticsearch/search | |
parent | df50371c347d00a8f70bd37459d633742bcfaa19 (diff) |
upgrade to lucene 5.5.0-snapshot-850c6c2
Diffstat (limited to 'core/src/main/java/org/elasticsearch/search')
6 files changed, 17 insertions, 15 deletions
diff --git a/core/src/main/java/org/elasticsearch/search/aggregations/bucket/geogrid/GeoHashGridParser.java b/core/src/main/java/org/elasticsearch/search/aggregations/bucket/geogrid/GeoHashGridParser.java index 6473b5ae7f..e1c52d50e8 100644 --- a/core/src/main/java/org/elasticsearch/search/aggregations/bucket/geogrid/GeoHashGridParser.java +++ b/core/src/main/java/org/elasticsearch/search/aggregations/bucket/geogrid/GeoHashGridParser.java @@ -20,7 +20,7 @@ package org.elasticsearch.search.aggregations.bucket.geogrid; import org.apache.lucene.index.LeafReaderContext; import org.apache.lucene.index.SortedNumericDocValues; -import org.apache.lucene.util.GeoHashUtils; +import org.apache.lucene.spatial.util.GeoHashUtils; import org.elasticsearch.common.geo.GeoPoint; import org.elasticsearch.common.xcontent.XContentParser; import org.elasticsearch.index.fielddata.MultiGeoPointValues; diff --git a/core/src/main/java/org/elasticsearch/search/aggregations/bucket/geogrid/InternalGeoHashGrid.java b/core/src/main/java/org/elasticsearch/search/aggregations/bucket/geogrid/InternalGeoHashGrid.java index e4c3fa2a52..538f1cb965 100644 --- a/core/src/main/java/org/elasticsearch/search/aggregations/bucket/geogrid/InternalGeoHashGrid.java +++ b/core/src/main/java/org/elasticsearch/search/aggregations/bucket/geogrid/InternalGeoHashGrid.java @@ -18,7 +18,7 @@ */ package org.elasticsearch.search.aggregations.bucket.geogrid; -import org.apache.lucene.util.GeoHashUtils; +import org.apache.lucene.spatial.util.GeoHashUtils; import org.apache.lucene.util.PriorityQueue; import org.elasticsearch.common.geo.GeoPoint; import org.elasticsearch.common.io.stream.StreamInput; diff --git a/core/src/main/java/org/elasticsearch/search/aggregations/metrics/geocentroid/GeoCentroidAggregator.java b/core/src/main/java/org/elasticsearch/search/aggregations/metrics/geocentroid/GeoCentroidAggregator.java index b5739f53f4..064ee1f5da 100644 --- a/core/src/main/java/org/elasticsearch/search/aggregations/metrics/geocentroid/GeoCentroidAggregator.java +++ b/core/src/main/java/org/elasticsearch/search/aggregations/metrics/geocentroid/GeoCentroidAggregator.java @@ -20,7 +20,7 @@ package org.elasticsearch.search.aggregations.metrics.geocentroid; import org.apache.lucene.index.LeafReaderContext; -import org.apache.lucene.util.GeoUtils; +import org.apache.lucene.spatial.util.GeoEncodingUtils; import org.elasticsearch.common.geo.GeoPoint; import org.elasticsearch.common.lease.Releasables; import org.elasticsearch.common.util.BigArrays; @@ -95,7 +95,7 @@ public final class GeoCentroidAggregator extends MetricsAggregator { pt[0] = pt[0] + (value.getLon() - pt[0]) / ++prevCounts; pt[1] = pt[1] + (value.getLat() - pt[1]) / prevCounts; } - centroids.set(bucket, GeoUtils.mortonHash(pt[0], pt[1])); + centroids.set(bucket, GeoEncodingUtils.mortonHash(pt[0], pt[1])); } } }; diff --git a/core/src/main/java/org/elasticsearch/search/aggregations/metrics/geocentroid/InternalGeoCentroid.java b/core/src/main/java/org/elasticsearch/search/aggregations/metrics/geocentroid/InternalGeoCentroid.java index b9eeb19354..36a04e7e08 100644 --- a/core/src/main/java/org/elasticsearch/search/aggregations/metrics/geocentroid/InternalGeoCentroid.java +++ b/core/src/main/java/org/elasticsearch/search/aggregations/metrics/geocentroid/InternalGeoCentroid.java @@ -19,7 +19,7 @@ package org.elasticsearch.search.aggregations.metrics.geocentroid; -import org.apache.lucene.util.GeoUtils; +import org.apache.lucene.spatial.util.GeoEncodingUtils; import org.elasticsearch.common.geo.GeoPoint; import org.elasticsearch.common.io.stream.StreamInput; import org.elasticsearch.common.io.stream.StreamOutput; @@ -140,7 +140,7 @@ public class InternalGeoCentroid extends InternalMetricsAggregation implements G out.writeVLong(count); if (centroid != null) { out.writeBoolean(true); - out.writeLong(GeoUtils.mortonHash(centroid.lon(), centroid.lat())); + out.writeLong(GeoEncodingUtils.mortonHash(centroid.lon(), centroid.lat())); } else { out.writeBoolean(false); } diff --git a/core/src/main/java/org/elasticsearch/search/aggregations/support/format/ValueFormatter.java b/core/src/main/java/org/elasticsearch/search/aggregations/support/format/ValueFormatter.java index a4b6c2cf28..555256b681 100644 --- a/core/src/main/java/org/elasticsearch/search/aggregations/support/format/ValueFormatter.java +++ b/core/src/main/java/org/elasticsearch/search/aggregations/support/format/ValueFormatter.java @@ -18,7 +18,7 @@ */ package org.elasticsearch.search.aggregations.support.format; -import org.apache.lucene.util.GeoHashUtils; +import org.apache.lucene.spatial.util.GeoHashUtils; import org.elasticsearch.common.io.stream.StreamInput; import org.elasticsearch.common.io.stream.StreamOutput; import org.elasticsearch.common.io.stream.Streamable; diff --git a/core/src/main/java/org/elasticsearch/search/suggest/completion/context/GeoContextMapping.java b/core/src/main/java/org/elasticsearch/search/suggest/completion/context/GeoContextMapping.java index f2f3d10215..4af90ab24a 100644 --- a/core/src/main/java/org/elasticsearch/search/suggest/completion/context/GeoContextMapping.java +++ b/core/src/main/java/org/elasticsearch/search/suggest/completion/context/GeoContextMapping.java @@ -22,7 +22,6 @@ package org.elasticsearch.search.suggest.completion.context; import org.apache.lucene.document.StringField; import org.apache.lucene.index.DocValuesType; import org.apache.lucene.index.IndexableField; -import org.apache.lucene.util.GeoHashUtils; import org.elasticsearch.ElasticsearchParseException; import org.elasticsearch.common.geo.GeoPoint; import org.elasticsearch.common.geo.GeoUtils; @@ -44,6 +43,9 @@ import java.util.Map; import java.util.Objects; import java.util.Set; +import static org.apache.lucene.spatial.util.GeoHashUtils.addNeighbors; +import static org.apache.lucene.spatial.util.GeoHashUtils.stringEncode; + /** * A {@link ContextMapping} that uses a geo location/area as a * criteria. @@ -150,7 +152,7 @@ public class GeoContextMapping extends ContextMapping { if (parser.nextToken() == Token.VALUE_NUMBER) { double lat = parser.doubleValue(); if (parser.nextToken() == Token.END_ARRAY) { - contexts.add(GeoHashUtils.stringEncode(lon, lat, precision)); + contexts.add(stringEncode(lon, lat, precision)); } else { throw new ElasticsearchParseException("only two values [lon, lat] expected"); } @@ -160,7 +162,7 @@ public class GeoContextMapping extends ContextMapping { } else { while (token != Token.END_ARRAY) { GeoPoint point = GeoUtils.parseGeoPoint(parser); - contexts.add(GeoHashUtils.stringEncode(point.getLon(), point.getLat(), precision)); + contexts.add(stringEncode(point.getLon(), point.getLat(), precision)); token = parser.nextToken(); } } @@ -171,7 +173,7 @@ public class GeoContextMapping extends ContextMapping { } else { // or a single location GeoPoint point = GeoUtils.parseGeoPoint(parser); - contexts.add(GeoHashUtils.stringEncode(point.getLon(), point.getLat(), precision)); + contexts.add(stringEncode(point.getLon(), point.getLat(), precision)); } return contexts; } @@ -194,7 +196,7 @@ public class GeoContextMapping extends ContextMapping { // we write doc values fields differently: one field for all values, so we need to only care about indexed fields if (lonField.fieldType().docValuesType() == DocValuesType.NONE) { spare.reset(latField.numericValue().doubleValue(), lonField.numericValue().doubleValue()); - geohashes.add(GeoHashUtils.stringEncode(spare.getLon(), spare.getLat(), precision)); + geohashes.add(stringEncode(spare.getLon(), spare.getLat(), precision)); } } } @@ -261,16 +263,16 @@ public class GeoContextMapping extends ContextMapping { } GeoPoint point = queryContext.getGeoPoint(); final Collection<String> locations = new HashSet<>(); - String geoHash = GeoHashUtils.stringEncode(point.getLon(), point.getLat(), minPrecision); + String geoHash = stringEncode(point.getLon(), point.getLat(), minPrecision); locations.add(geoHash); if (queryContext.getNeighbours().isEmpty() && geoHash.length() == this.precision) { - GeoHashUtils.addNeighbors(geoHash, locations); + addNeighbors(geoHash, locations); } else if (queryContext.getNeighbours().isEmpty() == false) { for (Integer neighbourPrecision : queryContext.getNeighbours()) { if (neighbourPrecision < geoHash.length()) { String truncatedGeoHash = geoHash.substring(0, neighbourPrecision); locations.add(truncatedGeoHash); - GeoHashUtils.addNeighbors(truncatedGeoHash, locations); + addNeighbors(truncatedGeoHash, locations); } } } |