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 Object
implements PlanNode

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BINDING_NAME
protected static final int	BULK_SIZE
protected Function<BindingSet, ValidationTuple>	mapper
private StackTraceElement[]	stackTrace
(package private) ValidationExecutionLogger	validationExecutionLogger

Constructor Summary

Constructors

Constructor	Description
AbstractBulkJoinPlanNode()

Method Summary

Modifier and Type	Method	Description
private List<BindingSet>	buildBindingSets(ArrayDeque<ValidationTuple> left, SailConnection connection, boolean skipBasedOnPreviousConnection, SailConnection previousStateConnection, Resource[] dataGraph)
boolean	equals(Object o)
private void	executeQuery(ArrayDeque<ValidationTuple> right, SailConnection connection, Dataset dataset, TupleExpr parsedQuery)
int	hashCode()
(package private) TupleExpr	parseQuery(String query)
boolean	producesSorted()
boolean	requiresSorted()
(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 Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface PlanNode

depth, getId, getPlanAsGraphvizDot, isGuaranteedEmpty, iterator, receiveLogger

Field Details

BINDING_NAME

public static final String BINDING_NAME

See Also:

• Constant Field Values

BULK_SIZE

protected static final int BULK_SIZE

See Also:

• Constant Field Values

stackTrace

private StackTraceElement[] stackTrace

mapper

protected Function<BindingSet, ValidationTuple> mapper

validationExecutionLogger

ValidationExecutionLogger validationExecutionLogger

Constructor Details

AbstractBulkJoinPlanNode

public AbstractBulkJoinPlanNode()

Method Details

parseQuery

TupleExpr parseQuery(String query)

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

private void updateQuery(TupleExpr parsedQuery,
 List<BindingSet> newBindindingSet)

buildBindingSets

private List<BindingSet> buildBindingSets(ArrayDeque<ValidationTuple> left,
 SailConnection connection,
 boolean skipBasedOnPreviousConnection,
 SailConnection previousStateConnection,
 Resource[] dataGraph)

producesSorted

public boolean producesSorted()

Specified by:

producesSorted in interface PlanNode

requiresSorted

public boolean requiresSorted()

Specified by:

requiresSorted in interface PlanNode

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object