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

public class ExecOpUnfold
extends UnaryExecutableOpBaseWithoutBlocking

To be used for UNFOLD clauses. See: https://awslabs.github.io/SPARQL-CDTs/spec/latest.html#description-of-unfold

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.jena.sparql.expr.Expr	expr
protected final org.apache.jena.sparql.core.Var	var1
protected final org.apache.jena.sparql.core.Var	var2

Fields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.UnaryExecutableOpBaseWithoutBlocking

MAX_BATCH_SIZE

Fields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps

collectExceptions, qpInfo

Constructor Summary

Constructors

Constructor	Description
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 Summary

Modifier and Type	Method	Description
protected 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 ExecutableOperatorStatsImpl	createStats()
void	resetStats()
protected void	unfoldList(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 void	unfoldMap(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, _process

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

concludeExecution, getStats, process, process

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

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: UnaryExecutableOpBase

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. If an exception occurs while processing the solution mapping, then this exception needs to be thrown.

Specified by:

_process in class UnaryExecutableOpBase

Throws:

ExecOpExecutionException

_concludeExecution

protected void _concludeExecution(IntermediateResultElementSink sink,
 ExecutionContext execCxt)

Description copied from class: UnaryExecutableOpBase

Implementations 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:

_concludeExecution in class UnaryExecutableOpBase

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

Overrides:

resetStats in class UnaryExecutableOpBase

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class UnaryExecutableOpBase

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)