Class AbstractBulkJoinPlanNode
- java.lang.Object
-
- org.eclipse.rdf4j.sail.shacl.ast.planNodes.AbstractBulkJoinPlanNode
-
- All Implemented Interfaces:
PlanNode
- Direct Known Subclasses:
BulkedExternalInnerJoin
,BulkedExternalLeftOuterJoin
public abstract class AbstractBulkJoinPlanNode extends java.lang.Object implements PlanNode
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
BINDING_NAME
protected static int
BULK_SIZE
protected java.util.function.Function<BindingSet,ValidationTuple>
mapper
private java.lang.StackTraceElement[]
stackTrace
(package private) ValidationExecutionLogger
validationExecutionLogger
-
Constructor Summary
Constructors Constructor Description AbstractBulkJoinPlanNode()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private java.util.List<BindingSet>
buildBindingSets(java.util.ArrayDeque<ValidationTuple> left, SailConnection connection, boolean skipBasedOnPreviousConnection, SailConnection previousStateConnection, Resource[] dataGraph)
boolean
equals(java.lang.Object o)
private void
executeQuery(java.util.ArrayDeque<ValidationTuple> right, SailConnection connection, Dataset dataset, TupleExpr parsedQuery)
int
hashCode()
(package private) TupleExpr
parseQuery(java.lang.String query)
boolean
producesSorted()
boolean
requiresSorted()
(package private) void
runQuery(java.util.ArrayDeque<ValidationTuple> left, java.util.ArrayDeque<ValidationTuple> right, SailConnection connection, TupleExpr parsedQuery, Dataset dataset, Resource[] dataGraph, boolean skipBasedOnPreviousConnection, SailConnection previousStateConnection)
private void
updateQuery(TupleExpr parsedQuery, java.util.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 Detail
-
BINDING_NAME
public static final java.lang.String BINDING_NAME
- See Also:
- Constant Field Values
-
BULK_SIZE
protected static final int BULK_SIZE
- See Also:
- Constant Field Values
-
stackTrace
private java.lang.StackTraceElement[] stackTrace
-
mapper
protected java.util.function.Function<BindingSet,ValidationTuple> mapper
-
validationExecutionLogger
ValidationExecutionLogger validationExecutionLogger
-
-
Method Detail
-
parseQuery
TupleExpr parseQuery(java.lang.String query)
-
runQuery
void runQuery(java.util.ArrayDeque<ValidationTuple> left, java.util.ArrayDeque<ValidationTuple> right, SailConnection connection, TupleExpr parsedQuery, Dataset dataset, Resource[] dataGraph, boolean skipBasedOnPreviousConnection, SailConnection previousStateConnection)
-
executeQuery
private void executeQuery(java.util.ArrayDeque<ValidationTuple> right, SailConnection connection, Dataset dataset, TupleExpr parsedQuery)
-
updateQuery
private void updateQuery(TupleExpr parsedQuery, java.util.List<BindingSet> newBindindingSet)
-
buildBindingSets
private java.util.List<BindingSet> buildBindingSets(java.util.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
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
-