Class ExecOpRequestOther

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<SPARQLRequest,WrappedRESTEndpoint>

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, NullaryExecutableOp

public class ExecOpRequestOther
extends BaseForExecOpRequest<SPARQLRequest,WrappedRESTEndpoint>

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, qpInfo

Constructor Summary

Constructors

Constructor	Description
ExecOpRequestOther(SPARQLRequest req, WrappedRESTEndpoint fm, boolean collectExceptions, QueryPlanningInfo qpInfo)

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 RESTRequest	createRESTRequest()
protected ExecutableOperatorStatsImpl	createStats()
protected void	process(String data, 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, getQueryPlanningInfo, 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, getQueryPlanningInfo

Constructor Details

ExecOpRequestOther

public ExecOpRequestOther(SPARQLRequest req,
 WrappedRESTEndpoint fm,
 boolean collectExceptions,
 QueryPlanningInfo qpInfo)

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

createRESTRequest

protected RESTRequest createRESTRequest()

process

protected void process(String data,
 IntermediateResultElementSink sink)
                throws ExecOpExecutionException

Throws:

ExecOpExecutionException

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

Overrides:

resetStats in class NullaryExecutableOpBase

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class BaseForExecOpRequest<SPARQLRequest,WrappedRESTEndpoint>