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.StringBINDING_NAMEprotected static intBULK_SIZEprotected java.util.function.Function<BindingSet,ValidationTuple>mapperprivate java.lang.StackTraceElement[]stackTrace(package private) ValidationExecutionLoggervalidationExecutionLogger
-
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)booleanequals(java.lang.Object o)private voidexecuteQuery(java.util.ArrayDeque<ValidationTuple> right, SailConnection connection, Dataset dataset, TupleExpr parsedQuery)inthashCode()(package private) TupleExprparseQuery(java.lang.String query)booleanproducesSorted()booleanrequiresSorted()(package private) voidrunQuery(java.util.ArrayDeque<ValidationTuple> left, java.util.ArrayDeque<ValidationTuple> right, SailConnection connection, TupleExpr parsedQuery, Dataset dataset, Resource[] dataGraph, boolean skipBasedOnPreviousConnection, SailConnection previousStateConnection)private voidupdateQuery(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:
producesSortedin interfacePlanNode
-
requiresSorted
public boolean requiresSorted()
- Specified by:
requiresSortedin interfacePlanNode
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equalsin classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
-