Class ExecOpUnfold
java.lang.Object
se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps
se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.UnaryExecutableOpBase
se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.UnaryExecutableOpBaseWithoutBlocking
se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.ExecOpUnfold
- All Implemented Interfaces:
StatsProvider,ExecutableOperator,UnaryExecutableOp
To be used for UNFOLD clauses.
See: https://awslabs.github.io/SPARQL-CDTs/spec/latest.html#description-of-unfold
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final org.apache.jena.sparql.expr.Exprprotected final org.apache.jena.sparql.core.Varprotected final org.apache.jena.sparql.core.VarFields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.UnaryExecutableOpBaseWithoutBlocking
MAX_BATCH_SIZEFields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps
collectExceptions, qpInfo -
Constructor Summary
ConstructorsConstructorDescriptionExecOpUnfold(org.apache.jena.sparql.expr.Expr expr, org.apache.jena.sparql.core.Var var1, org.apache.jena.sparql.core.Var var2, boolean collectExceptions, QueryPlanningInfo qpInfo) -
Method Summary
Modifier and TypeMethodDescriptionprotected void_concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt) Implementations of this function need to conclude the execution of this operator and send the remaining result elements (if any) to the given sink.protected void_process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt) Implementations of this function need to process the given solution mapping as input and send the produced result elements (if any) to the given sink.protected ExecutableOperatorStatsImplvoidprotected voidunfoldList(org.apache.jena.graph.impl.LiteralLabel lit, SolutionMapping inputSolMap, IntermediateResultElementSink sink) protected List<SolutionMapping> unfoldList1(List<org.apache.jena.cdt.CDTValue> list, SolutionMapping smIn) protected List<SolutionMapping> unfoldList2(List<org.apache.jena.cdt.CDTValue> list, SolutionMapping smIn) protected voidunfoldMap(org.apache.jena.graph.impl.LiteralLabel lit, SolutionMapping smIn, IntermediateResultElementSink sink) Methods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.UnaryExecutableOpBaseWithoutBlocking
_process, _processMethods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.UnaryExecutableOpBase
concludeExecution, getStats, process, processMethods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps
getExceptionsCaughtDuringExecution, getQueryPlanningInfo, recordExceptionCaughtDuringExecutionMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface se.liu.ida.hefquin.engine.queryplan.executable.ExecutableOperator
getExceptionsCaughtDuringExecution, getQueryPlanningInfo
-
Field Details
-
expr
protected final org.apache.jena.sparql.expr.Expr expr -
var1
protected final org.apache.jena.sparql.core.Var var1 -
var2
protected final org.apache.jena.sparql.core.Var var2
-
-
Constructor Details
-
ExecOpUnfold
public ExecOpUnfold(org.apache.jena.sparql.expr.Expr expr, org.apache.jena.sparql.core.Var var1, org.apache.jena.sparql.core.Var var2, boolean collectExceptions, QueryPlanningInfo qpInfo)
-
-
Method Details
-
_process
protected void _process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt) throws ExecOpExecutionException Description copied from class:UnaryExecutableOpBaseImplementations of this function need to process the given solution mapping as input and send the produced result elements (if any) to the given sink. If an exception occurs while processing the solution mapping, then this exception needs to be thrown.- Specified by:
_processin classUnaryExecutableOpBase- Throws:
ExecOpExecutionException
-
_concludeExecution
Description copied from class:UnaryExecutableOpBaseImplementations of this function need to conclude the execution of this operator and send the remaining result elements (if any) to the given sink. If an exception occurs during this process, then this exception needs to be thrown.- Specified by:
_concludeExecutionin classUnaryExecutableOpBase
-
resetStats
public void resetStats()- Specified by:
resetStatsin interfaceStatsProvider- Overrides:
resetStatsin classUnaryExecutableOpBase
-
createStats
- Overrides:
createStatsin classUnaryExecutableOpBase
-
unfoldList
protected void unfoldList(org.apache.jena.graph.impl.LiteralLabel lit, SolutionMapping inputSolMap, IntermediateResultElementSink sink) -
unfoldList1
protected List<SolutionMapping> unfoldList1(List<org.apache.jena.cdt.CDTValue> list, SolutionMapping smIn) -
unfoldList2
protected List<SolutionMapping> unfoldList2(List<org.apache.jena.cdt.CDTValue> list, SolutionMapping smIn) -
unfoldMap
protected void unfoldMap(org.apache.jena.graph.impl.LiteralLabel lit, SolutionMapping smIn, IntermediateResultElementSink sink)
-