Class AbstractBulkJoinPlanNode
java.lang.Object
org.eclipse.rdf4j.sail.shacl.ast.planNodes.AbstractBulkJoinPlanNode
- All Implemented Interfaces:
PlanNode
- Direct Known Subclasses:
BulkedExternalInnerJoin
,BulkedExternalLeftOuterJoin
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final String
protected static final int
protected Function
<BindingSet, ValidationTuple> private StackTraceElement[]
(package private) ValidationExecutionLogger
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate List
<BindingSet> buildBindingSets
(ArrayDeque<ValidationTuple> left, SailConnection connection, boolean skipBasedOnPreviousConnection, SailConnection previousStateConnection, Resource[] dataGraph) boolean
private void
executeQuery
(ArrayDeque<ValidationTuple> right, SailConnection connection, Dataset dataset, TupleExpr parsedQuery) int
hashCode()
(package private) TupleExpr
parseQuery
(String query) boolean
boolean
(package private) void
runQuery
(ArrayDeque<ValidationTuple> left, ArrayDeque<ValidationTuple> right, SailConnection connection, TupleExpr parsedQuery, Dataset dataset, Resource[] dataGraph, boolean skipBasedOnPreviousConnection, SailConnection previousStateConnection) private void
updateQuery
(TupleExpr parsedQuery, List<BindingSet> newBindindingSet) Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.eclipse.rdf4j.sail.shacl.ast.planNodes.PlanNode
depth, getId, getPlanAsGraphvizDot, isGuaranteedEmpty, iterator, receiveLogger
-
Field Details
-
BINDING_NAME
- See Also:
-
BULK_SIZE
protected static final int BULK_SIZE- See Also:
-
stackTrace
-
mapper
-
validationExecutionLogger
ValidationExecutionLogger validationExecutionLogger
-
-
Constructor Details
-
AbstractBulkJoinPlanNode
public AbstractBulkJoinPlanNode()
-
-
Method Details
-
parseQuery
-
runQuery
void runQuery(ArrayDeque<ValidationTuple> left, ArrayDeque<ValidationTuple> right, SailConnection connection, TupleExpr parsedQuery, Dataset dataset, Resource[] dataGraph, boolean skipBasedOnPreviousConnection, SailConnection previousStateConnection) -
executeQuery
private void executeQuery(ArrayDeque<ValidationTuple> right, SailConnection connection, Dataset dataset, TupleExpr parsedQuery) -
updateQuery
-
buildBindingSets
private List<BindingSet> buildBindingSets(ArrayDeque<ValidationTuple> left, SailConnection connection, boolean skipBasedOnPreviousConnection, SailConnection previousStateConnection, Resource[] dataGraph) -
producesSorted
public boolean producesSorted()- Specified by:
producesSorted
in interfacePlanNode
-
requiresSorted
public boolean requiresSorted()- Specified by:
requiresSorted
in interfacePlanNode
-
equals
-
hashCode
public int hashCode()
-