diff --git a/pom.xml b/pom.xml index a3c857fe566..1192508ed15 100644 --- a/pom.xml +++ b/pom.xml @@ -613,7 +613,7 @@ com.maxmind.geoip2 geoip2 - 0.4.0 + 2.6.0 org.apache.httpcomponents diff --git a/server/src/main/java/io/druid/segment/realtime/firehose/WikipediaIrcDecoder.java b/server/src/main/java/io/druid/segment/realtime/firehose/WikipediaIrcDecoder.java index 9ddfabaf961..1ef270b572e 100644 --- a/server/src/main/java/io/druid/segment/realtime/firehose/WikipediaIrcDecoder.java +++ b/server/src/main/java/io/druid/segment/realtime/firehose/WikipediaIrcDecoder.java @@ -24,9 +24,10 @@ import com.fasterxml.jackson.annotation.JsonProperty; import com.google.common.collect.ImmutableList; import com.google.common.collect.Lists; import com.google.common.collect.Maps; +import com.maxmind.db.CHMCache; import com.maxmind.geoip2.DatabaseReader; import com.maxmind.geoip2.exception.GeoIp2Exception; -import com.maxmind.geoip2.model.Omni; +import com.maxmind.geoip2.model.CityResponse; import com.metamx.common.logger.Logger; import io.druid.data.input.InputRow; import io.druid.data.input.Row; @@ -123,7 +124,7 @@ class WikipediaIrcDecoder implements IrcDecoder private DatabaseReader openGeoIpDb(File geoDb) { try { - DatabaseReader reader = new DatabaseReader(geoDb); + DatabaseReader reader = new DatabaseReader.Builder(geoDb).withCache(new CHMCache()).build(); log.info("Using geo ip database at [%s].", geoDb); return reader; } catch (IOException e) { @@ -196,7 +197,7 @@ class WikipediaIrcDecoder implements IrcDecoder if (anonymous) { try { final InetAddress ip = InetAddress.getByName(ipMatch.group()); - final Omni lookup = geoLookup.omni(ip); + final CityResponse lookup = geoLookup.city(ip); dimensions.put("continent", lookup.getContinent().getName()); dimensions.put("country", lookup.getCountry().getName());