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

Class BaseForExecOpSolMapsRequest<ReqType extends DataRetrievalRequest,MemberType extends FederationMember>

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.BaseForExecOpSolMapsRequest<ReqType,MemberType>

All Implemented Interfaces:

StatsProvider, ExecutableOperator, NullaryExecutableOp

Direct Known Subclasses:

ExecOpRequestSPARQL

public abstract class BaseForExecOpSolMapsRequest<ReqType extends DataRetrievalRequest,MemberType extends FederationMember>
extends BaseForExecOpRequest<ReqType,MemberType>

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
BaseForExecOpSolMapsRequest(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 ExecutableOperatorStatsImpl	createStats()
protected abstract SolMapsResponse	performRequest(FederationAccessManager fedAccessMgr)
protected void	process(SolMapsResponse response, IntermediateResultElementSink sink)
void	resetStats()

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

execute, getStats

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

BaseForExecOpSolMapsRequest

public BaseForExecOpSolMapsRequest(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

process

protected void process(SolMapsResponse response,
 IntermediateResultElementSink sink)

performRequest

protected abstract SolMapsResponse performRequest(FederationAccessManager fedAccessMgr)
                                           throws FederationAccessException

Throws:

FederationAccessException

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

Overrides:

resetStats in class NullaryExecutableOpBase

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class BaseForExecOpRequest<ReqType extends DataRetrievalRequest,MemberType extends FederationMember>