Package se.liu.ida.hefquin.engine.queryplan.executable.impl.ops

Class BaseForExecOpRequestWithPaging<ReqType extends DataRetrievalRequest,MemberType extends FederationMember,PageReqType extends DataRetrievalRequest,PageRespType extends DataRetrievalResponse>

java.lang.Object

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.NullaryExecutableOpBase

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOpRequest<ReqType,MemberType>

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOpRequestWithPaging<ReqType,MemberType,PageReqType,PageRespType>

All Implemented Interfaces:

StatsProvider, ExecutableOperator, NullaryExecutableOp

public abstract class BaseForExecOpRequestWithPaging<ReqType extends DataRetrievalRequest,MemberType extends FederationMember,PageReqType extends DataRetrievalRequest,PageRespType extends DataRetrievalResponse>
extends BaseForExecOpRequest<ReqType,MemberType>

Base class for implementations of request operators with requests that have to be broken into multiple requests to handle paging.

Field Summary

Fields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOpRequest

fm, req

Fields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.NullaryExecutableOpBase

timeAtExecEnd, timeAtExecStart

Fields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps

collectExceptions

Constructor Summary

Constructors

Constructor	Description
BaseForExecOpRequestWithPaging(ReqType req, MemberType fm, boolean collectExceptions)

Method Summary

Modifier and Type	Method	Description
protected final void	_execute(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to execute the algorithm of this operator and send the result elements (if any) to the given sink.
protected abstract void	consumeResponse(PageRespType response, IntermediateResultElementSink sink)
protected abstract PageReqType	createPageRequest(int pageNumber)
protected abstract boolean	isLastPage(PageRespType response)
protected abstract PageRespType	performPageRequest(PageReqType pageReq, FederationAccessManager fedAccessMgr)

Methods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOpRequest

createStats

Methods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.NullaryExecutableOpBase

execute, getStats, resetStats

Methods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps

getExceptionsCaughtDuringExecution, recordExceptionCaughtDuringExecution

Methods inherited from class java.lang.Object

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

Methods inherited from interface se.liu.ida.hefquin.engine.queryplan.executable.ExecutableOperator

getExceptionsCaughtDuringExecution

Constructor Details

BaseForExecOpRequestWithPaging

public BaseForExecOpRequestWithPaging(ReqType req,
 MemberType fm,
 boolean collectExceptions)

Method Details

_execute

protected final void _execute(IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                       throws ExecOpExecutionException

Description copied from class: NullaryExecutableOpBase

Implementations of this function need to execute the algorithm of this operator and send the result elements (if any) to the given sink. If an exception occurs during this process, then this exception needs to either be collected or be thrown, depending on whether BaseForExecOps.collectExceptions is set to true.

Specified by:

_execute in class NullaryExecutableOpBase

Throws:

ExecOpExecutionException

createPageRequest

protected abstract PageReqType createPageRequest(int pageNumber)

performPageRequest

protected abstract PageRespType performPageRequest(PageReqType pageReq,
 FederationAccessManager fedAccessMgr)
                                            throws FederationAccessException

Throws:

FederationAccessException

consumeResponse

protected abstract void consumeResponse(PageRespType response,
 IntermediateResultElementSink sink)

isLastPage

protected abstract boolean isLastPage(PageRespType response)