com.senseidb.search.node
Class SenseiScatterGatherHandler

java.lang.Object
  com.senseidb.search.node.AbstractSenseiScatterGatherHandler<SenseiRequest,SenseiResult>
      com.senseidb.search.node.SenseiScatterGatherHandler

All Implemented Interfaces:

com.linkedin.norbert.javacompat.network.ScatterGatherHandler<SenseiRequest,SenseiResult,SenseiResult,Integer>

public class SenseiScatterGatherHandler
extends AbstractSenseiScatterGatherHandler<SenseiRequest,SenseiResult>

Constructor Summary

SenseiScatterGatherHandler(SenseiRequest request, SenseiRequestScatterRewriter reqRewriter)

Method Summary

SenseiRequest	customizeRequest(SenseiRequest senseiReq, com.linkedin.norbert.javacompat.cluster.Node node, Set<Integer> partitions)
long	getTimeoutMillis()
SenseiResult	mergeResults(SenseiRequest request, List<SenseiResult> resultList) Merge results on the client/broker side.
void	setTimeoutMillis(long timeoutMillis)

Methods inherited from class com.senseidb.search.node.AbstractSenseiScatterGatherHandler

gatherResponses

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SenseiScatterGatherHandler

public SenseiScatterGatherHandler(SenseiRequest request,
                                  SenseiRequestScatterRewriter reqRewriter)

Method Detail

setTimeoutMillis

public void setTimeoutMillis(long timeoutMillis)

Overrides:

setTimeoutMillis in class AbstractSenseiScatterGatherHandler<SenseiRequest,SenseiResult>

getTimeoutMillis

public long getTimeoutMillis()

Overrides:

getTimeoutMillis in class AbstractSenseiScatterGatherHandler<SenseiRequest,SenseiResult>

mergeResults

public SenseiResult mergeResults(SenseiRequest request,
                                 List<SenseiResult> resultList)

Description copied from class: AbstractSenseiScatterGatherHandler

Merge results on the client/broker side. It likely works differently from the one in the search node.

Specified by:

mergeResults in class AbstractSenseiScatterGatherHandler<SenseiRequest,SenseiResult>

resultList - the list of results from all the requested partitions.

Returns:

one single result instance that is merged from the result list.

customizeRequest

public SenseiRequest customizeRequest(SenseiRequest senseiReq,
                                      com.linkedin.norbert.javacompat.cluster.Node node,
                                      Set<Integer> partitions)

Specified by:

customizeRequest in class AbstractSenseiScatterGatherHandler<SenseiRequest,SenseiResult>