Query/Filter Facet should support 64bit counter, not 32

closes #3419
elastic · Jul 31, 2013 · 10011ff · 10011ff
1 parent db0a5f0
commit 10011ff
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/src/main/java/org/elasticsearch/search/facet/filter/FilterFacetExecutor.java b/src/main/java/org/elasticsearch/search/facet/filter/FilterFacetExecutor.java
@@ -40,7 +40,7 @@ public class FilterFacetExecutor extends FacetExecutor {
 
     private final Filter filter;
 
-    int count = -1;
+    long count = -1;
 
     public FilterFacetExecutor(Filter filter) {
         this.filter = filter;
@@ -82,7 +82,7 @@ public void executePost(List<ContextDocIdSet> docSets) throws IOException {
 
     class Collector extends FacetExecutor.Collector {
 
-        private int count = 0;
+        private long count = 0;
         private Bits bits;
 
         @Override

diff --git a/src/main/java/org/elasticsearch/search/facet/filter/InternalFilterFacet.java b/src/main/java/org/elasticsearch/search/facet/filter/InternalFilterFacet.java
@@ -83,7 +83,7 @@ public Facet reduce(ReduceContext context) {
         if (facets.size() == 1) {
             return facets.get(0);
         }
-        int count = 0;
+        long count = 0;
         for (Facet facet : facets) {
             count += ((FilterFacet) facet).getCount();
         }

diff --git a/src/main/java/org/elasticsearch/search/facet/query/InternalQueryFacet.java b/src/main/java/org/elasticsearch/search/facet/query/InternalQueryFacet.java
@@ -81,7 +81,7 @@ public Facet reduce(ReduceContext context) {
         if (facets.size() == 1) {
             return facets.get(0);
         }
-        int count = 0;
+        long count = 0;
         for (Facet facet : facets) {
             count += ((QueryFacet) facet).getCount();
         }

diff --git a/src/main/java/org/elasticsearch/search/facet/query/QueryFacetExecutor.java b/src/main/java/org/elasticsearch/search/facet/query/QueryFacetExecutor.java
@@ -43,7 +43,7 @@ public class QueryFacetExecutor extends FacetExecutor {
     private final Filter filter;
 
     // default to not initialized
-    int count = -1;
+    long count = -1;
 
     public QueryFacetExecutor(Query query) {
         this.query = query;
@@ -91,7 +91,7 @@ public void executePost(List<ContextDocIdSet> docSets) throws IOException {
 
     class Collector extends FacetExecutor.Collector {
 
-        private int count = 0;
+        private long count = 0;
         private Bits bits;
 
         @Override