com.senseidb.svc.impl
Class AbstractSenseiCoreService<Req extends AbstractSenseiRequest,Res extends AbstractSenseiResult>

java.lang.Object
  com.senseidb.svc.impl.AbstractSenseiCoreService<Req,Res>

Direct Known Subclasses:

CoreSenseiServiceImpl, SysSenseiCoreServiceImpl

public abstract class AbstractSenseiCoreService<Req extends AbstractSenseiRequest,Res extends AbstractSenseiResult>
extends Object

Field Summary

protected SenseiCore	_core
protected long	_timeout

Constructor Summary

AbstractSenseiCoreService(SenseiCore core)

Method Summary

Res	execute(Req senseiReq)
abstract Res	getEmptyResultInstance(Throwable error)
abstract com.linkedin.norbert.network.Serializer<Req,Res>	getSerializer()
abstract Res	handlePartitionedRequest(Req r, List<com.browseengine.bobo.api.BoboIndexReader> readerList, SenseiQueryBuilderFactory queryBuilderFactory)
abstract Res	mergePartitionedResults(Req r, List<Res> reqList)

Methods inherited from class java.lang.Object

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

Field Detail

_timeout

protected long _timeout

_core

protected final SenseiCore _core

Constructor Detail

AbstractSenseiCoreService

public AbstractSenseiCoreService(SenseiCore core)

Method Detail

execute

public final Res execute(Req senseiReq)

handlePartitionedRequest

public abstract Res handlePartitionedRequest(Req r,
                                             List<com.browseengine.bobo.api.BoboIndexReader> readerList,
                                             SenseiQueryBuilderFactory queryBuilderFactory)
                                                                   throws Exception

Throws:

Exception

mergePartitionedResults

public abstract Res mergePartitionedResults(Req r,
                                            List<Res> reqList)

getEmptyResultInstance

public abstract Res getEmptyResultInstance(Throwable error)

getSerializer

public abstract com.linkedin.norbert.network.Serializer<Req,Res> getSerializer()