Merge pull request #76 from o19s/fixing_map

Fixing map variable name for #75

data/esci/index.sh

@@ -7,4 +7,4 @@ echo "Initializing UBI..."
 curl -s -X POST "http://localhost:9200/_plugins/ubi/initialize"
 
 echo "Indexing queries and events..."
-curl  -X POST 'http://localhost:9200/index-name/_bulk?pretty' --data-binary @ubi_queries_events.ndjson -H "Content-Type: application/x-ndjson"
+curl  -X POST 'http://localhost:9200/_bulk?pretty' --data-binary @ubi_queries_events.ndjson -H "Content-Type: application/x-ndjson"

scripts/opensearch-scripts/get-rank-aggregated-ctr.sh

@@ -0,0 +1,11 @@
+#!/bin/bash -e
+
+curl -s "http://localhost:9200/rank_aggregated_ctr/_search" -H "Content-type: application/json" -d'{
+  "query": {
+    "range": {
+      "ctr": {
+        "gt": 0 
+      }
+    }
+  }
+}'

src/main/java/org/opensearch/eval/engine/OpenSearchEngine.java

@@ -645,8 +645,8 @@ public Map<Integer, Double> getRankAggregatedClickThrough(final int maxRank) thr
                 final List<LongTermsBucket> positionBuckets = positionTerms.lterms().buckets().array();
 
                 for(final LongTermsBucket positionBucket : positionBuckets) {
-                    LOGGER.debug("Inserting client event from position {} with click count {}", positionBucket.key(), (double) positionBucket.docCount());
-                    impressionCounts.put(Integer.valueOf(positionBucket.key()), (double) positionBucket.docCount());
+                    LOGGER.debug("Inserting click event from position {} with click count {}", positionBucket.key(), (double) positionBucket.docCount());
+                    clickCounts.put(Integer.valueOf(positionBucket.key()), (double) positionBucket.docCount());
                 }
 
             }
@@ -681,6 +681,7 @@ public Map<Integer, Double> getRankAggregatedClickThrough(final int maxRank) thr
 
         }
 
+        // Index the calculated values.
         indexRankAggregatedClickthrough(rankAggregatedClickThrough);
 
         return rankAggregatedClickThrough;