summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/prelude/query/WeightedSetItem.java
diff options
context:
space:
mode:
Diffstat (limited to 'container-search/src/main/java/com/yahoo/prelude/query/WeightedSetItem.java')
-rw-r--r--container-search/src/main/java/com/yahoo/prelude/query/WeightedSetItem.java22
1 files changed, 11 insertions, 11 deletions
diff --git a/container-search/src/main/java/com/yahoo/prelude/query/WeightedSetItem.java b/container-search/src/main/java/com/yahoo/prelude/query/WeightedSetItem.java
index d5ca15f10b9..e75a8417328 100644
--- a/container-search/src/main/java/com/yahoo/prelude/query/WeightedSetItem.java
+++ b/container-search/src/main/java/com/yahoo/prelude/query/WeightedSetItem.java
@@ -138,11 +138,8 @@ public class WeightedSetItem extends SimpleTaggableItem {
public void disclose(Discloser discloser) {
super.disclose(discloser);
discloser.addProperty("index", indexName);
- for (Map.Entry<Object, Integer> entry : set.entrySet()) {
- WordItem subitem = new WordItem(entry.getKey().toString(), indexName);
- subitem.setWeight(entry.getValue());
- discloser.addChild(subitem);
- }
+ for (Map.Entry<Object, Integer> entry : set.entrySet())
+ discloser.addChild(asItem(entry));
}
@Override
@@ -150,17 +147,20 @@ public class WeightedSetItem extends SimpleTaggableItem {
encodeThis(buffer);
int itemCount = 1;
for (Map.Entry<Object, Integer> entry : set.entrySet()) {
- Object key = entry.getKey();
- if (key instanceof Long) {
- new PureWeightedInteger((Long)key, entry.getValue()).encode(buffer);
- } else {
- new PureWeightedString(key.toString(), entry.getValue()).encode(buffer);
- }
+ asItem(entry).encode(buffer);
itemCount++;
}
return itemCount;
}
+ private PureWeightedItem asItem(Map.Entry<Object, Integer> entry) {
+ Object key = entry.getKey();
+ if (key instanceof Long)
+ return new PureWeightedInteger((Long)key, entry.getValue());
+ else
+ return new PureWeightedString(key.toString(), entry.getValue());
+ }
+
@Override
protected void encodeThis(ByteBuffer buffer) {
super.encodeThis(buffer);