diff options
Diffstat (limited to 'core/src/main/java/org/elasticsearch/search/internal/ShardSearchTransportRequest.java')
-rw-r--r-- | core/src/main/java/org/elasticsearch/search/internal/ShardSearchTransportRequest.java | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/core/src/main/java/org/elasticsearch/search/internal/ShardSearchTransportRequest.java b/core/src/main/java/org/elasticsearch/search/internal/ShardSearchTransportRequest.java index 41f060cc1f..0c4a0515df 100644 --- a/core/src/main/java/org/elasticsearch/search/internal/ShardSearchTransportRequest.java +++ b/core/src/main/java/org/elasticsearch/search/internal/ShardSearchTransportRequest.java @@ -54,8 +54,8 @@ public class ShardSearchTransportRequest extends TransportRequest implements Sha } public ShardSearchTransportRequest(SearchRequest searchRequest, ShardId shardId, int numberOfShards, - AliasFilter aliasFilter, long nowInMillis) { - this.shardSearchLocalRequest = new ShardSearchLocalRequest(searchRequest, shardId, numberOfShards, aliasFilter, nowInMillis); + AliasFilter aliasFilter, float indexBoost, long nowInMillis) { + this.shardSearchLocalRequest = new ShardSearchLocalRequest(searchRequest, shardId, numberOfShards, aliasFilter, indexBoost, nowInMillis); this.originalIndices = new OriginalIndices(searchRequest); } @@ -112,6 +112,11 @@ public class ShardSearchTransportRequest extends TransportRequest implements Sha } @Override + public float indexBoost() { + return shardSearchLocalRequest.indexBoost(); + } + + @Override public long nowInMillis() { return shardSearchLocalRequest.nowInMillis(); } |