Challenge redislabs-training#5

jeff-romine · Jun 6, 2021 · ba3a8f9 · ba3a8f9
1 parent ceeabc2
commit ba3a8f9
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/main/java/com/redislabs/university/RU102J/dao/SiteGeoDaoRedisImpl.java b/src/main/java/com/redislabs/university/RU102J/dao/SiteGeoDaoRedisImpl.java
@@ -91,7 +91,7 @@ private Set<Site> findSitesByGeoWithCapacity(GeoQuery query) {
              // START Challenge #5
              // TODO: Challenge #5: Get the sites matching the geo query, store them
 
-             List<GeoRadiusResponse> radiusResponses =
+             final List<GeoRadiusResponse> radiusResponses =
                  jedis.georadius(RedisSchema.getSiteGeoKey(), coord.getLng(),
                                  coord.getLat(), radius, radiusUnit);
 
@@ -103,10 +103,10 @@ private Set<Site> findSitesByGeoWithCapacity(GeoQuery query) {
                      .map(Site::new).collect(Collectors.toSet());
 
              // START Challenge #5
-             Pipeline pipeline = jedis.pipelined();
-             Map<Long, Response<Double>> scores = new HashMap<>(sites.size());
+             final Pipeline pipeline = jedis.pipelined();
+             final Map<Long, Response<Double>> scores = new HashMap<>(sites.size());
              // TODO: Challenge #5: Add the code that populates the scores HashMap...
-             for (Site site : sites) {
+             for (final Site site : sites) {
                  final Response<Double> score =
                      pipeline.zscore(RedisSchema.getCapacityRankingKey(),String.valueOf(site.getId()));
                  scores.put(site.getId(), score);
@@ -115,7 +115,7 @@ private Set<Site> findSitesByGeoWithCapacity(GeoQuery query) {
              pipeline.sync();
              // END Challenge #5
 
-             for (Site site : sites) {
+             for (final Site site : sites) {
                  if (scores.get(site.getId()).get() >= capacityThreshold) {
                      results.add(site);
                  }