summaryrefslogtreecommitdiff
path: root/core/src/main/java/org/elasticsearch/search/dfs/AggregatedDfs.java
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/main/java/org/elasticsearch/search/dfs/AggregatedDfs.java')
-rw-r--r--core/src/main/java/org/elasticsearch/search/dfs/AggregatedDfs.java7
1 files changed, 3 insertions, 4 deletions
diff --git a/core/src/main/java/org/elasticsearch/search/dfs/AggregatedDfs.java b/core/src/main/java/org/elasticsearch/search/dfs/AggregatedDfs.java
index d8330e5ec1..d762540caa 100644
--- a/core/src/main/java/org/elasticsearch/search/dfs/AggregatedDfs.java
+++ b/core/src/main/java/org/elasticsearch/search/dfs/AggregatedDfs.java
@@ -22,7 +22,6 @@ package org.elasticsearch.search.dfs;
import com.carrotsearch.hppc.ObjectObjectHashMap;
import com.carrotsearch.hppc.cursors.ObjectObjectCursor;
-
import org.apache.lucene.index.Term;
import org.apache.lucene.search.CollectionStatistics;
import org.apache.lucene.search.TermStatistics;
@@ -72,8 +71,8 @@ public class AggregatedDfs implements Streamable {
termStatistics = HppcMaps.newMap(size);
for (int i = 0; i < size; i++) {
Term term = new Term(in.readString(), in.readBytesRef());
- TermStatistics stats = new TermStatistics(in.readBytesRef(),
- in.readVLong(),
+ TermStatistics stats = new TermStatistics(in.readBytesRef(),
+ in.readVLong(),
DfsSearchResult.subOne(in.readVLong()));
termStatistics.put(term, stats);
}
@@ -84,7 +83,7 @@ public class AggregatedDfs implements Streamable {
@Override
public void writeTo(final StreamOutput out) throws IOException {
out.writeVInt(termStatistics.size());
-
+
for (ObjectObjectCursor<Term, TermStatistics> c : termStatistics()) {
Term term = (Term) c.key;
out.writeString(term.field());