5

次のような Java クラスがあります (GeoPoint は Elasticsearch タイプです)。

private Long id;
private Integer genre;
private String cityName;
private GeoPoint geoPoint;
private Date lastUpdate;
private Double lat;
private Double lon;

私が使用する Elasticsearch マッピングは次のとおりです。

{
    "location": {
        "properties": {
            "id": {"type": "long"},
            "genre": {"type": "integer"},
            "cityName": {"type": "string"},
            "geoPoint": {
                "type": "geo_point",
                "geohash": true,
                "geohash_prefix": true,
                "geohash_precision": 7
            },
            "lastUpdate": {"type": "date", format: "yyyy/MM/dd HH:mm:ss"}
        }
    }
}

インデックスを作成しようとすると、次の例外が発生します。

org.elasticsearch.ElasticsearchParseException: フィールドは緯度/経度またはジオハッシュのいずれかでなければなりません

GeoUtils クラスの 381 行目から例外がスローされます。GeoPoint プロパティと同様に、マッピング クラスの Double lat フィールドと lon フィールドのチェックの直後に発生します。

ElasticSearch のドキュメントで提案されているように、geoPoint のフィールド タイプを geo_point に設定したのに、なぜ機能しないのかわかりません。

更新 1

Java クラス。

public class UserLocation implements Serializable {

    private Long id;
    private Integer genre;
    private String cityName;
    private GeoPoint geoPoint;
    private Date lastUpdate;

    public UserLocation () {
    }

    public UserLocation (UserLocationLite userLocationLite) {

        this.id = userLocationLite.getId();
        this.genre = userLocationLite.getGenre();
        this.cityName = userLocationLite.getCity();
        this.geoPoint =
                new GeoPoint(userLocationLite.getLatitude(), userLocationLite.getLongitude());
        this.lastUpdate = userLocationLite.getActivity();
    }

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public Integer getGenre() {
        return genre;
    }

    public void setGenre(Integer genre) {
        this.genre = genre;
    }

    public String getCityName() {
        return cityName;
    }

    public void setCityName(String cityName) {
        this.cityName = cityName;
    }

    public GeoPoint getGeoPoint() {
        return geoPoint;
    }

    public void setGeoPoint(GeoPoint geoPoint) {
        this.geoPoint = geoPoint;
    }

    public Date getLastUpdate() {
        return lastUpdate;
    }

    public void setLastUpdate(Date lastUpdate) {
        this.lastUpdate = lastUpdate;
    }

}

索引付けするメソッド。

@Override
public boolean save(String id, R r) {

    try {

        return this.transportClient.prepareIndex(this.index, this.type, id)
                .setSource(this.objectMapper.writeValueAsString(r))
                .execute().actionGet().isCreated();
    } catch (JsonProcessingException e) {

        e.printStackTrace();
    }

    return false;
}

ここで、R は別のクラス (この場合は UserLocation クラス) 用に実装されたジェネリック型の 1 つであり、次のようにシリアル化されます。

{"id":40,"genre":1,"cityName":"Madrid","geoPoint":{"lat":42.626595,"lon":-0.488439,"geohash":"ezrm5c0vx832"},"lastUpdate":1402144560000}

更新 2

現在、Java クラス構造は正常に機能しています。

public class UserLocationSearch implements Serializable {

    private Long id;
    private Integer genre;
    private String cityName;
    @JsonIgnore
    private GeoPoint geoPoint;
    private Date lastUpdate;

    public UserLocationSearch() {

        this.geoPoint = new GeoPoint();
    }

    public UserLocationSearch(UserLocationLite userLocationLite) {

        this.id = userLocationLite.getId();
        this.genre = userLocationLite.getGenre();
        this.cityName = userLocationLite.getCity();
        this.geoPoint =
                new GeoPoint(userLocationLite.getLatitude(), userLocationLite.getLongitude());
        this.lastUpdate = userLocationLite.getActivity();
    }

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public Integer getGenre() {
        return genre;
    }

    public void setGenre(Integer genre) {
        this.genre = genre;
    }

    public String getCityName() {
        return cityName;
    }

    public void setCityName(String cityName) {
        this.cityName = cityName;
    }

    public GeoPoint getGeoPoint() {
        return geoPoint;
    }

    public void setGeoPoint(GeoPoint geoPoint) {
        this.geoPoint = geoPoint;
    }

public String getGeohash() {
    return this.geoPoint.getGeohash();
}

public void setGeohash(String geohash) {
    this.geoPoint.resetFromGeoHash(geohash);
}

public Date getLastUpdate() {
    return lastUpdate;
}

public void setLastUpdate(Date lastUpdate) {
    this.lastUpdate = lastUpdate;
}

}

しかし今、私は別の質問があります。

文書を取得する場合。

GET /ユーザー/場所/40

{
   "_index": "user",
   "_type": "location",
   "_id": "40",
   "_version": 7,
   "found": true,
   "_source": {
      "id": 40,
      "genre": 1,
      "cityName": "Madrid",
      "lastUpdate": 1402144560000,
      "geohash": "ezrm5c28d9x0"
   }
}

geohash には 12 文字ありますが、マッピングでは geohash の精度は 7 に設定されています...

GET /ユーザー/場所/_mapping

{
   "user": {
      "mappings": {
         "location": {
            "properties": {
               "cityName": {
                  "type": "string"
               },
               "genre": {
                  "type": "integer"
               },
               "geoPoint": {
                  "type": "geo_point",
                  "geohash": true,
                  "geohash_prefix": true,
                  "geohash_precision": 7
               },
               "geohash": {
                  "type": "string"
               },
               "id": {
                  "type": "long"
               },
               "lastUpdate": {
                  "type": "date",
                  "format": "yyyy/MM/dd HH:mm:ss"
               }
            }
         }
      }
   }
}

これは動作がおかしいということでしょうか？

更新 3

現在のクラス。

public class UserLocationSearch implements Serializable {

    private Long id;
    private Integer genre;
    private String cityName;
    private Location location;
    private GeoPoint geoPoint;
    private Date lastUpdate;

    public UserLocationSearch() {

    }

    public UserLocationSearch(UserLocationLite userLocationLite) {

        this.id = userLocationLite.getId();
        this.genre = userLocationLite.getGenre();
        this.cityName = userLocationLite.getCity();
        this.location = new Location(userLocationLite.getLatitude(), userLocationLite.getLongitude());
        this.geoPoint = new GeoPoint(this.location.getGeohash());
        this.lastUpdate = userLocationLite.getActivity();
    }

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public Integer getGenre() {
        return genre;
    }

    public void setGenre(Integer genre) {
        this.genre = genre;
    }

    public String getCityName() {
        return cityName;
    }

    public void setCityName(String cityName) {
        this.cityName = cityName;
    }

    public Location getLocation() {
        return location;
    }

    public void setLocation(Location location) {
        this.location = location;
    }

    public GeoPoint getGeoPoint() {
        return geoPoint;
    }

    public void setGeoPoint(GeoPoint geoPoint) {
        this.geoPoint = geoPoint;
    }

    public Date getLastUpdate() {
        return lastUpdate;
    }

    public void setLastUpdate(Date lastUpdate) {
        this.lastUpdate = lastUpdate;
    }

    public static class GeoPoint{

        private String geohash;

        public GeoPoint() {

        }

        public GeoPoint(String geohash) {

            this.geohash = geohash;
        }

        public String getGeohash() {
            return geohash;
        }

        public void setGeohash(String geohash) {
            this.geohash = geohash;
        }
    }

    public static class Location{

        private Double lat;
        private Double lon;

        public Location() {

        }

        public Location(Double lat, Double lon) {

            this.lat = lat;
            this.lon = lon;
        }

        public Double getLat() {
            return lat;
        }

        public void setLat(Double lat) {
            this.lat = lat;
        }

        public Double getLon() {
            return lon;
        }

        public void setLon(Double lon) {
            this.lon = lon;
        }

        @JsonIgnore
        public String getGeohash(){

            return new org.elasticsearch.common.geo.GeoPoint(this.lat, this.lon).getGeohash();
        }

    }

}

そのマッピング。

{
    "location": {
        "properties": {
            "id": {"type": "long"},
            "genre": {"type": "integer"},
            "cityName": {"type": "string"},
            "location": {
                "type": "geo_point",
                "geohash": false
            },
            "geoPoint": {
                "type": "geo_point",
                "geohash": true,
                "geohash_prefix": true,
                "geohash_precision": 7
            },
            "lastUpdate": {"type": "date", format: "yyyy/MM/dd HH:mm:ss"}
        }
    }
}

検索します。

距離別（正常に動作します）。

GET /ユーザー/場所/_search

{
  "query": {
    "match_all": {}
  },
  "filter": {
    "geo_distance": {
      "distance": "100km",
      "location": {
        "lat": 42.5,
        "lon": -0.49
      }
    }
  }
}

geohash による (「geohash_precision: 7」でマッピングされているため、7 を超える精度は無視されます)。

GET /ユーザー/場所/_search

{
  "query": {
    "filtered": {
      "filter": {
        "geohash_cell": {
          "geoPoint": {
            "geohash": "ezrm5c0y5rh8"
          },
          "neighbors": true, 
          "precision": 7
        }
      }
    }
  }
}

結論

org.elasticsearch.common.geo.GeoHashUtils.GeoPoint クラスが実際の Elastic バージョンと互換性がない理由がわかりません。

しかし、@jkbkot によって提供されたトラックに従って、完全な互換性を得るために、独自の GeoPoint および Location クラスを実装することを決定しました。

4

1 に答える 1