public void setup()

in src/main/java/com/google/solutions/df/log/aggregations/common/IpToGeoDoFn.java [53:63]


  public void setup() throws GeoIp2Exception, IOException {
    GcsPath path = GcsPath.fromUri(URI.create(geoDbPath));
    Storage storage = StorageOptions.getDefaultInstance().getService();
    readerChannel = storage.reader(path.getBucket(), path.getObject());
    inputStream = Channels.newInputStream(readerChannel);
    reader =
        new DatabaseReader.Builder(inputStream)
            .fileMode(FileMode.MEMORY)
            .withCache(new CHMCache())
            .build();
  }