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

Class BaseForExecOpRequestWithTPFPaging<ReqType extends DataRetrievalRequest,MemberType extends FederationMember,PageReqType extends DataRetrievalRequest>

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, NullaryExecutableOp

Direct Known Subclasses:

BaseForExecOpTriplePatternRequestWithTPF, ExecOpRequestBRTPF

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

Base class for implementations of paging-based request operators where pages are TPFResponse objects.

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
BaseForExecOpRequestWithTPFPaging(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 void	consumeMatchingTriples(Iterable<Triple> itTriples, IntermediateResultElementSink sink)
protected abstract Iterator<SolutionMapping>	convert(Iterable<Triple> itTriples)
protected abstract PageReqType	createPageRequest(String nextPageURL)
protected PageReqType	createPageRequest(TPFResponse previousPage)
protected ExecutableOperatorStatsImpl	createStats()
protected boolean	isLastPage(TPFResponse response)
protected abstract TPFResponse	performPageRequest(PageReqType pageReq, FederationAccessManager fedAccessMgr)
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

BaseForExecOpRequestWithTPFPaging

public BaseForExecOpRequestWithTPFPaging(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 PageReqType createPageRequest(TPFResponse previousPage)

isLastPage

protected boolean isLastPage(TPFResponse response)

consumeMatchingTriples

protected void consumeMatchingTriples(Iterable<Triple> itTriples,
 IntermediateResultElementSink sink)

createPageRequest

protected abstract PageReqType createPageRequest(String nextPageURL)

performPageRequest

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

Throws:

FederationAccessException

convert

protected abstract Iterator<SolutionMapping> convert(Iterable<Triple> itTriples)

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>