import org.elasticsearch.search.aggregations.bucket.geogrid.InternalGeoHashGrid; //导入依赖的package包/类
private static AggregationResult reduceAggregationResults(ElasticsearchSearchQueryBase query, List<Aggregation> aggs) {
    if (aggs.size() == 0) {
        throw new MemgraphException("Cannot reduce zero sized aggregation list");
    }
    Aggregation first = aggs.get(0);
    if (first instanceof HistogramAggregation || first instanceof InternalHistogram || first instanceof InternalDateHistogram) {
        return reduceHistogramResults(query, aggs);
    }
    if (first instanceof RangeAggregation || first instanceof InternalRange) {
        return reduceRangeResults(query, aggs);
    }
    if (first instanceof PercentilesAggregation || first instanceof Percentiles) {
        return reducePercentilesResults(query, aggs);
    }
    if (first instanceof TermsAggregation || first instanceof InternalTerms) {
        return reduceTermsResults(query, aggs);
    }
    if (first instanceof GeohashAggregation || first instanceof InternalGeoHashGrid) {
        return reduceGeohashResults(query, aggs);
    }
    if (first instanceof StatisticsAggregation || first instanceof InternalExtendedStats) {
        return reduceStatisticsResults(aggs);
    }
    throw new MemgraphException("Unhandled aggregation type: " + first.getClass().getName());
}
 

import org.elasticsearch.search.aggregations.bucket.geogrid.InternalGeoHashGrid; //导入依赖的package包/类
private static AggregationResult reduceAggregationResults(ElasticsearchSearchQueryBase query, List<Aggregation> aggs) {
    if (aggs.size() == 0) {
        throw new VertexiumException("Cannot reduce zero sized aggregation list");
    }
    Aggregation first = aggs.get(0);
    if (first instanceof HistogramAggregation || first instanceof InternalHistogram || first instanceof InternalDateHistogram) {
        return reduceHistogramResults(query, aggs);
    }
    if (first instanceof RangeAggregation || first instanceof InternalRange) {
        return reduceRangeResults(query, aggs);
    }
    if (first instanceof PercentilesAggregation || first instanceof Percentiles) {
        return reducePercentilesResults(query, aggs);
    }
    if (first instanceof TermsAggregation || first instanceof InternalTerms) {
        return reduceTermsResults(query, aggs);
    }
    if (first instanceof GeohashAggregation || first instanceof InternalGeoHashGrid) {
        return reduceGeohashResults(query, aggs);
    }
    if (first instanceof StatisticsAggregation || first instanceof InternalExtendedStats) {
        return reduceStatisticsResults(aggs);
    }
    throw new VertexiumException("Unhandled aggregation type: " + first.getClass().getName());
}
 

import org.elasticsearch.search.aggregations.bucket.geogrid.InternalGeoHashGrid; //导入依赖的package包/类
@Test
public void geoHashGrid() throws SQLFeatureNotSupportedException, SqlParseException {
    Aggregations result = query(String.format("SELECT COUNT(*) FROM %s/location GROUP BY geohash_grid(field='center',precision=5) ", TEST_INDEX));
    InternalGeoHashGrid grid = result.get("geohash_grid(field=center,precision=5)");
    Collection<GeoHashGrid.Bucket> buckets = grid.getBuckets();
    for (GeoHashGrid.Bucket bucket : buckets) {
        Assert.assertTrue(bucket.getKeyAsString().equals("w2fsm") || bucket.getKeyAsString().equals("w0p6y") );
        Assert.assertEquals(1,bucket.getDocCount());
    }
}
 

import org.elasticsearch.search.aggregations.bucket.geogrid.InternalGeoHashGrid; //导入依赖的package包/类
@Test
public void geoHashGrid() throws SQLFeatureNotSupportedException, SqlParseException {
    Aggregations result = query(String.format("SELECT COUNT(*) FROM %s/location GROUP BY geohash_grid(field='center',precision=5) ", TestsConstants.TEST_INDEX));
    InternalGeoHashGrid grid = result.get("geohash_grid(field=center,precision=5)");
    Collection<GeoHashGrid.Bucket> buckets = grid.getBuckets();
    for (GeoHashGrid.Bucket bucket : buckets) {
        Assert.assertTrue(bucket.getKey().toString().equals("[4.98779296875, 105.00732421875]") || bucket.getKey().toString().equals("[0.50537109375, 100.48095703125]") );
        Assert.assertEquals(1,bucket.getDocCount());
    }
}
 

import org.elasticsearch.search.aggregations.bucket.geogrid.InternalGeoHashGrid; //导入依赖的package包/类
@Test
public void geoHashGrid() throws SQLFeatureNotSupportedException, SqlParseException {
    Aggregations result = query(String.format("SELECT COUNT(*) FROM %s/location GROUP BY geohash_grid(field='center',precision=5) ", TEST_INDEX_LOCATION));
    InternalGeoHashGrid grid = result.get("geohash_grid(field=center,precision=5)");
    Collection<? extends InternalMultiBucketAggregation.InternalBucket> buckets = grid.getBuckets();
    for (InternalMultiBucketAggregation.InternalBucket bucket : buckets) {
        Assert.assertTrue(bucket.getKeyAsString().equals("w2fsm") || bucket.getKeyAsString().equals("w0p6y") );
        Assert.assertEquals(1,bucket.getDocCount());
    }
}