com.senseidb.search.node
Class SenseiSysScatterGatherHandler

java.lang.Object
  com.senseidb.search.node.AbstractSenseiScatterGatherHandler<SenseiRequest,SenseiSystemInfo>
      com.senseidb.search.node.SenseiSysScatterGatherHandler

All Implemented Interfaces:

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

public class SenseiSysScatterGatherHandler
extends AbstractSenseiScatterGatherHandler<SenseiRequest,SenseiSystemInfo>

Constructor Summary

SenseiSysScatterGatherHandler(SenseiRequest request, Comparator<String> versionComparator)

Method Summary

SenseiRequest	customizeRequest(SenseiRequest senseiRequest, com.linkedin.norbert.javacompat.cluster.Node node, Set<Integer> partitions)
SenseiSystemInfo	mergeResults(SenseiRequest request, List<SenseiSystemInfo> resultList) Merge results on the client/broker side.

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

gatherResponses, getTimeoutMillis, setTimeoutMillis

Methods inherited from class java.lang.Object

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

Constructor Detail

SenseiSysScatterGatherHandler

public SenseiSysScatterGatherHandler(SenseiRequest request,
                                     Comparator<String> versionComparator)

Method Detail

customizeRequest

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

Specified by:

customizeRequest in class AbstractSenseiScatterGatherHandler<SenseiRequest,SenseiSystemInfo>

mergeResults

public SenseiSystemInfo mergeResults(SenseiRequest request,
                                     List<SenseiSystemInfo> 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,SenseiSystemInfo>

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

Returns:

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