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

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, NullaryExecutableOp

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

Base class for implementations of request operators with requests that return triples and that can be performed as is. The latter means that such requests do not have to be broken into multiple requests as would be the case when interacting with, e.g., a TPF server which employs paging. For interactions with TPF servers, there is a different base class: BaseForExecOpTriplePatternRequestWithTPF.

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
BaseForExecOpTriplesRequest(ReqType req, MemberType fm, boolean collectExceptions)

Method Summary

Modifier and Type	Method	Description
protected 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 Iterator<? extends SolutionMapping>	convert(Iterable<? extends Triple> itTriples)
protected abstract TriplesResponse	performRequest(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

BaseForExecOpTriplesRequest

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

Method Details

_execute

protected void _execute(IntermediateResultElementSink sink,
 ExecutionContext execCxt)

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

performRequest

protected abstract TriplesResponse performRequest(FederationAccessManager fedAccessMgr)

convert

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