Package | Description |
---|---|
com.bigdata.bop |
This package provides an API for query operators.
|
com.bigdata.bop.ap | |
com.bigdata.bop.bindingSet | |
com.bigdata.bop.bset | |
com.bigdata.bop.constraint |
This package provides implementations for operators which impose constraints
on elements visited by some access path.
|
com.bigdata.bop.controller |
This package provides operators for subquery, including UNION, STEPS,
and STAR (transitive closure).
|
com.bigdata.bop.join | |
com.bigdata.bop.joinGraph |
This package provides support for join graphs, query optimization,
and generating full query plans from a join graph and the
evaluation order identified by a query optimizer.
|
com.bigdata.bop.joinGraph.rto | |
com.bigdata.bop.rdf.join | |
com.bigdata.bop.rdf.update |
This package provides bigdata operators for SPARQL update.
|
com.bigdata.bop.solutions |
This package provides distinct, sort, and aggregation operators.
|
com.bigdata.rdf.graph |
The GAS (Gather Apply Scatter) API was developed for PowerGraph
(aka GraphLab 2.1).
|
com.bigdata.rdf.internal.constraints | |
com.bigdata.rdf.internal.encoder | |
com.bigdata.rdf.lexicon | |
com.bigdata.rdf.relation.rule | |
com.bigdata.rdf.rules | |
com.bigdata.rdf.sail |
This package contains the SAIL that allow bigdata to be used as a backend for
the Sesame 2.x platform.
|
com.bigdata.rdf.sparql.ast |
This package contains an Abstract Syntax Tree which provides an intermediate translation
target for SPARQL parsers.
|
com.bigdata.rdf.sparql.ast.cache | |
com.bigdata.rdf.sparql.ast.eval | |
com.bigdata.rdf.sparql.ast.explainhints | |
com.bigdata.rdf.sparql.ast.optimizers | |
com.bigdata.rdf.sparql.ast.service |
This package provides support for SPARQL 1.1 Federated Query, including the
special case of "service" end points which live within the same JVM and use
direct method calls rather than SPARQL Query and remote (HTTP) end points
for which we will generate an appropriate SPARQL query.
|
com.bigdata.rdf.spo |
This package defines a statement model using long term identifiers rather than
RDF Value objects.
|
com.bigdata.rdf.store |
This package provides several realizations of an RDF database using the bigdata
architecture, including one suitable for temporary data, one suitable for local
processing (single host), and one designed for scale-out on commodity hardware.
|
com.bigdata.relation.rule |
This package includes an abstraction layer for rules.
|
com.bigdata.relation.rule.eval |
This package supports rule evaluation.
|
com.bigdata.relation.rule.eval.pipeline |
This package implements a pipeline join.
|
com.bigdata.service.fts | |
com.bigdata.service.geospatial | |
com.bigdata.service.geospatial.impl |
Modifier and Type | Class and Description |
---|---|
class |
Var<E>
A variable.
|
Modifier and Type | Field and Description |
---|---|
static IVariable<?>[] |
IVariable.EMPTY
An empty
IVariable array. |
Modifier and Type | Method and Description |
---|---|
IVariable[] |
NamedSolutionSetRef.getJoinVars() |
IVariable<? extends E> |
IBind.getVar()
Return the variable which will be bound to the result of evaluating the
associated value expression.
|
IVariable<E> |
Constant.getVar() |
IVariable<? extends E> |
Bind.getVar()
Return the variable which will be bound to the result of evaluating the
associated value expression.
|
static IVariable[] |
BOpUtility.toArray(Iterator<IVariable<?>> it)
Return an array containing the
IVariable s visited by the
iterator. |
IVariable<?> |
IVariableFactory.var()
Return a new anonymous variable.
|
Modifier and Type | Method and Description |
---|---|
static Iterator<IVariable<?>> |
BOpUtility.getArgumentVariables(BOp op)
Return the variables from the operator's arguments.
|
static Set<IVariable<?>> |
BOpUtility.getSharedVars(BOp p,
BOp c)
Return the variable references shared by two operators.
|
static Iterator<IVariable<?>> |
BOpUtility.getSpannedVariables(BOp op)
Return the distinct variables recursively using a pre-order traversal
present whether in the operator tree or on annotations attached to
operators.
|
Iterator<Map.Entry<IVariable,IConstant>> |
ContextBindingSet.iterator() |
Iterator<Map.Entry<IVariable,IConstant>> |
IBindingSet.iterator()
Visits the bindings.
|
Iterator<IVariable> |
ContextBindingSet.vars() |
Iterator<IVariable> |
IBindingSet.vars()
Visits the bound variables.
|
Modifier and Type | Method and Description |
---|---|
Predicate<E> |
IPredicate.asBound(IVariable<?> var,
IConstant<?> val)
Return a new instance in which all occurrences of the given variable have
been replaced by the specified constant.
|
static IBindingSet |
BOpContext.bind(IBindingSet left,
IBindingSet right,
IConstraint[] constraints,
IVariable[] varsToKeep)
Copy the values for variables from the source
IBindingSet to the
destination IBindingSet . |
void |
ContextBindingSet.clear(IVariable var) |
void |
IBindingSet.clear(IVariable var)
Clear any binding for the variable.
|
int |
Var.compareTo(IVariable<E> o)
Orders variables alphabetically.
|
static long |
BOpUtility.copy(Iterator<IBindingSet[]> source,
IBlockingBuffer<IBindingSet[]> sink,
IBlockingBuffer<IBindingSet[]> sink2,
IBindingSet mergeSolution,
IVariable<?>[] selectVars,
IConstraint[] constraints,
BOpStats stats)
Copy binding sets from the source to the sink(s).
|
IBindingSet |
ContextBindingSet.copy(IVariable[] variablesToKeep) |
IBindingSet |
IBindingSet.copy(IVariable[] variablesToKeep)
Return a shallow copy of the binding set, eliminating unnecessary
variables.
|
IBindingSet |
ContextBindingSet.copyMinusErrors(IVariable[] variablesToKeep) |
IBindingSet |
IBindingSet.copyMinusErrors(IVariable[] variablesToKeep)
Return a shallow copy of the binding set, eliminating unnecessary
variables and error values (equal to Constant.errorValueConstant()).
|
static int |
BOpUtility.countVarOccurrencesOutsideProjections(BOp op,
IVariable inputVar)
Counts the number of occurrences of a BOp inside another BOp.
|
IConstant |
ContextBindingSet.get(IVariable var) |
IConstant |
IBindingSet.get(IVariable var)
Return the binding for the variable.
|
static String |
NamedSolutionSetRefUtility.getFQN(String namespace,
String localName,
IVariable[] joinVars)
Return the fully qualified name for a named solution set NOT attached to
a query.
|
static ICloseableIterator<IBindingSet[]> |
NamedSolutionSetRefUtility.getSolutionSet(ISolutionSetManager sparqlCache,
IBTreeManager localIndexManager,
String namespace,
long timestamp,
String localName,
IVariable[] joinVars,
int chunkCapacity)
Resolve the pre-existing named solution set returning an iterator that
will visit the solutions (access path scan).
|
static ISolutionSetStats |
NamedSolutionSetRefUtility.getSolutionSetStats(ISolutionSetManager sparqlCache,
IBTreeManager localIndexManager,
String namespace,
long timestamp,
String localName,
IVariable[] joinVars)
Resolve the pre-existing named solution set returning its
ISolutionSetStats . |
boolean |
ContextBindingSet.isBound(IVariable var) |
boolean |
IBindingSet.isBound(IVariable var)
Return
true iff the variable is bound. |
static INamedSolutionSetRef |
NamedSolutionSetRefUtility.newInstance(String namespace,
long timestamp,
String localName,
IVariable[] joinVars)
Factory for
INamedSolutionSetRef s that will be resolved against a
KB view identified by a namespace and timestamp. |
static INamedSolutionSetRef |
NamedSolutionSetRefUtility.newInstance(UUID queryId,
String namedSet,
IVariable[] joinVars)
Factory for
INamedSolutionSetRef s that will be resolved against
the IRunningQuery identified by the specified queryId. |
void |
ContextBindingSet.set(IVariable var,
IConstant val) |
void |
IBindingSet.set(IVariable var,
IConstant val)
Bind the variable to the value.
|
Modifier and Type | Method and Description |
---|---|
static IVariable[] |
BOpUtility.toArray(Iterator<IVariable<?>> it)
Return an array containing the
IVariable s visited by the
iterator. |
Constructor and Description |
---|
Bind(IVariable<E> var,
IValueExpression<E> expr) |
Constant(IVariable<E> var,
E value)
Create a constant which models a variable bound to that constant.
|
Modifier and Type | Method and Description |
---|---|
Predicate<E> |
Predicate.asBound(IVariable<?> var,
IConstant<?> val) |
Modifier and Type | Method and Description |
---|---|
Iterator<Map.Entry<IVariable,IConstant>> |
HashBindingSet.iterator() |
Iterator<Map.Entry<IVariable,IConstant>> |
ListBindingSet.iterator() |
Iterator<Map.Entry<IVariable,IConstant>> |
EmptyBindingSet.iterator() |
Iterator<IVariable> |
HashBindingSet.vars() |
Iterator<IVariable> |
ListBindingSet.vars() |
Iterator<IVariable> |
EmptyBindingSet.vars() |
Modifier and Type | Method and Description |
---|---|
protected void |
TestIBindingSet.assertEqual(IBindingSet actual,
IVariable<?>[] vars,
IConstant<?>[] vals)
Compare actual and expected, where the latter is expressed using
(vars,vals).
|
void |
HashBindingSet.clear(IVariable var) |
void |
ListBindingSet.clear(IVariable var) |
void |
EmptyBindingSet.clear(IVariable var) |
HashBindingSet |
HashBindingSet.copy(IVariable[] variablesToKeep) |
IBindingSet |
ListBindingSet.copy(IVariable[] variablesToKeep) |
EmptyBindingSet |
EmptyBindingSet.copy(IVariable[] variablesToDrop) |
IBindingSet |
HashBindingSet.copyMinusErrors(IVariable[] variablesToKeep) |
IBindingSet |
ListBindingSet.copyMinusErrors(IVariable[] variablesToKeep) |
EmptyBindingSet |
EmptyBindingSet.copyMinusErrors(IVariable[] variablesToDrop)
Returns the same object.
|
IConstant |
HashBindingSet.get(IVariable var) |
IConstant |
ListBindingSet.get(IVariable var) |
IConstant |
EmptyBindingSet.get(IVariable var) |
boolean |
HashBindingSet.isBound(IVariable var) |
boolean |
ListBindingSet.isBound(IVariable var) |
boolean |
EmptyBindingSet.isBound(IVariable var) |
protected abstract IBindingSet |
TestIBindingSet.newBindingSet(IVariable<?>[] vars,
IConstant<?>[] vals) |
protected IBindingSet |
TestHashBindingSet.newBindingSet(IVariable<?>[] vars,
IConstant<?>[] vals) |
protected IBindingSet |
TestListBindingSet.newBindingSet(IVariable<?>[] vars,
IConstant<?>[] vals) |
void |
HashBindingSet.set(IVariable var,
IConstant val) |
void |
ListBindingSet.set(IVariable var,
IConstant val) |
void |
EmptyBindingSet.set(IVariable var,
IConstant val) |
Constructor and Description |
---|
HashBindingSet(HashBindingSet src,
IVariable[] variablesToKeep)
Copy constructor (used by clone, copy).
|
ListBindingSet(IVariable[] vars,
IConstant[] vals)
Alternative constructor.
|
ListBindingSet(ListBindingSet src,
IVariable[] variablesToKeep)
Copy constructor (used by clone, copy).
|
Modifier and Type | Method and Description |
---|---|
IVariable<?>[] |
CopyOp.getSelect() |
Modifier and Type | Method and Description |
---|---|
IVariable<T> |
INConstraint.getVariable() |
Modifier and Type | Method and Description |
---|---|
protected INConstraint |
TestInHashMap.newINConstraint(IVariable<?> var,
IConstant<?>[] vals) |
protected abstract INConstraint |
TestINConstraint.newINConstraint(IVariable<?> var,
IConstant<?>[] vals) |
protected INConstraint |
TestInBinarySearch.newINConstraint(IVariable<?> var,
IConstant<?>[] vals) |
Constructor and Description |
---|
EQ(IVariable<?> x,
IVariable<?> y) |
EQ(IVariable<?> x,
IVariable<?> y) |
EQConstant(IVariable<?> x,
IConstant<?> y) |
INBinarySearch(IVariable<T> x,
IConstant<T>[] set) |
INHashMap(IVariable<T> x,
IConstant<T>[] set) |
NE(IVariable<?> x,
IVariable<?> y) |
NE(IVariable<?> x,
IVariable<?> y) |
NEConstant(IVariable<?> x,
IConstant<?> y) |
Modifier and Type | Method and Description |
---|---|
IVariable[] |
INamedSolutionSetRef.getJoinVars()
The ordered set of variables that specifies the ordered set of components
in the key for the desired index over the named solution set (required,
but may be an empty array).
|
Modifier and Type | Field and Description |
---|---|
protected IVariable<?> |
JVMHashJoinUtility.askVar |
protected IVariable<?> |
FastRangeCountOp.ChunkTask.countVar
The variable that gets bound to the fast range count.
|
protected IVariable<?>[] |
JVMHashJoinUtility.joinVars
The join variables.
|
protected IVariable<?>[] |
JVMHashJoinUtility.selectVars
The variables to be retained (aka projected out) (optional, all variables
are retained if not specified).
|
Modifier and Type | Method and Description |
---|---|
IVariable<?> |
IHashJoinUtility.getAskVar()
The variable bound based on whether or not a solution survives an
"EXISTS" graph pattern (optional).
|
IVariable<?> |
JVMHashJoinUtility.getAskVar() |
IVariable<?> |
HTreeHashJoinUtility.getAskVar() |
protected IVariable<?> |
FastRangeCountOp.getCountVar() |
protected IVariable<?> |
DistinctTermScanOp.getDistinctVar() |
IVariable<?>[] |
IHashJoinUtility.getJoinVars()
The join variables.
|
IVariable<?>[] |
JVMHashJoinUtility.getJoinVars() |
IVariable<?>[] |
HTreeHashJoinUtility.getJoinVars() |
IVariable<?>[] |
IDistinctFilter.getProjectedVars()
The variables that are being projected out of the DISTINCT filter.
|
IVariable<?>[] |
JVMDistinctFilter.getProjectedVars() |
protected IVariable<?>[] |
DistinctTermScanOp.getSelect() |
protected IVariable<?>[] |
FastRangeCountOp.getSelect() |
protected IVariable<?>[] |
NestedLoopJoinOp.getSelect() |
IVariable<?>[] |
IHashJoinUtility.getSelectVars()
The variables to be retained (optional, all variables are retained if
not specified).
|
IVariable<?>[] |
JVMHashJoinUtility.getSelectVars() |
IVariable<?>[] |
HTreeHashJoinUtility.getSelectVars() |
IVariable<?>[] |
PipelineJoin.variablesToKeep() |
Modifier and Type | Method and Description |
---|---|
long |
HTreePipelinedHashJoinUtility.acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out,
ICloseableIterator<IBindingSet[]> itr,
NamedSolutionSetStats stats,
IConstraint[] joinConstraints,
PipelineOp subquery,
IBindingSet[] bsFromBindingsSetSource,
IVariable<?>[] projectInVars,
IVariable<?> askVar,
boolean isLastInvocation,
int distinctProjectionBufferThreshold,
int incomingBindingsBufferThreshold,
BOpContext<IBindingSet> context) |
long |
HTreePipelinedHashJoinUtility.acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out,
ICloseableIterator<IBindingSet[]> itr,
NamedSolutionSetStats stats,
IConstraint[] joinConstraints,
PipelineOp subquery,
IBindingSet[] bsFromBindingsSetSource,
IVariable<?>[] projectInVars,
IVariable<?> askVar,
boolean isLastInvocation,
int distinctProjectionBufferThreshold,
int incomingBindingsBufferThreshold,
BOpContext<IBindingSet> context) |
long |
PipelinedHashJoinUtility.acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out,
ICloseableIterator<IBindingSet[]> itr,
NamedSolutionSetStats stats,
IConstraint[] joinConstraints,
PipelineOp subquery,
IBindingSet[] bsFromBindingsSetSource,
IVariable<?>[] projectInVars,
IVariable<?> askVar,
boolean isLastInvocation,
int distinctProjectionBufferThreshold,
int incomingBindingsBufferThreshold,
BOpContext<IBindingSet> context)
AcceptAndOutputSolutions is a special method for building the hash index
of the
JVMPipelinedHashIndex , which accepts and immediately
forwards relevant solutions (non-blocking index). |
long |
PipelinedHashJoinUtility.acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out,
ICloseableIterator<IBindingSet[]> itr,
NamedSolutionSetStats stats,
IConstraint[] joinConstraints,
PipelineOp subquery,
IBindingSet[] bsFromBindingsSetSource,
IVariable<?>[] projectInVars,
IVariable<?> askVar,
boolean isLastInvocation,
int distinctProjectionBufferThreshold,
int incomingBindingsBufferThreshold,
BOpContext<IBindingSet> context)
AcceptAndOutputSolutions is a special method for building the hash index
of the
JVMPipelinedHashIndex , which accepts and immediately
forwards relevant solutions (non-blocking index). |
long |
JVMPipelinedHashJoinUtility.acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out,
ICloseableIterator<IBindingSet[]> itr,
NamedSolutionSetStats stats,
IConstraint[] joinConstraints,
PipelineOp subquery,
IBindingSet[] bsFromBindingsSetSource,
IVariable<?>[] projectInVars,
IVariable<?> askVar,
boolean isLastInvocation,
int distinctProjectionBufferThreshold,
int incomingBindingsBufferThreshold,
BOpContext<IBindingSet> context) |
long |
JVMPipelinedHashJoinUtility.acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out,
ICloseableIterator<IBindingSet[]> itr,
NamedSolutionSetStats stats,
IConstraint[] joinConstraints,
PipelineOp subquery,
IBindingSet[] bsFromBindingsSetSource,
IVariable<?>[] projectInVars,
IVariable<?> askVar,
boolean isLastInvocation,
int distinctProjectionBufferThreshold,
int incomingBindingsBufferThreshold,
BOpContext<IBindingSet> context) |
protected void |
AbstractHashJoinUtilityTestCase.doHashJoinTest(JoinTypeEnum joinType,
IVariable<?>[] joinVars,
IVariable<?>[] selectVars,
IConstraint[] constraints,
List<IBindingSet> left,
List<IBindingSet> right,
IBindingSet[] expected)
Test helper for required or optional join tests.
|
protected void |
AbstractHashJoinUtilityTestCase.doHashJoinTest(JoinTypeEnum joinType,
IVariable<?>[] joinVars,
IVariable<?>[] selectVars,
IConstraint[] constraints,
List<IBindingSet> left,
List<IBindingSet> right,
IBindingSet[] expected)
Test helper for required or optional join tests.
|
void |
HTreePipelinedHashJoinUtility.hashJoinAndEmit(IBindingSet[] chunk,
BOpStats stats,
IBuffer<IBindingSet> outputBuffer,
IConstraint[] joinConstraints,
IVariable<?> askVar)
Executes the hash join for the chunk of solutions that is passed in
over rightSolutions and outputs the solutions.
|
void |
JVMPipelinedHashJoinUtility.hashJoinAndEmit(IBindingSet[] chunk,
BOpStats stats,
IBuffer<IBindingSet> outputBuffer,
IConstraint[] joinConstraints,
IVariable<?> askVar)
Executes the hash join for the chunk of solutions that is passed in
over rightSolutions and outputs the solutions.
|
protected abstract PipelineOp |
AbstractHashJoinOpTestCase.newJoin(BOp[] args,
int joinId,
IVariable<IV>[] joinVars,
Predicate<IV> predOp,
UUID queryId,
NV... annotations)
Return a new join operator instance for the test.
|
protected PipelineOp |
TestJVMHashJoinOp.newJoin(BOp[] args,
int joinId,
IVariable<IV>[] joinVars,
Predicate<IV> predOp,
UUID queryId,
NV... annotations) |
protected PipelineOp |
TestHTreeHashJoinOp.newJoin(BOp[] args,
int joinId,
IVariable<IV>[] joinVars,
Predicate<IV> predOp,
UUID queryId,
NV... annotations) |
protected HTreeHashJoinUtility.BS[] |
HTreeHashJoinUtility.vector(IBindingSet[] leftSolutions,
IVariable<?>[] joinVars,
IVariable<?>[] selectVars,
boolean ignoreUnboundVariables,
AtomicInteger vectorSize)
Vector a chunk of solutions.
|
protected HTreeHashJoinUtility.BS[] |
HTreeHashJoinUtility.vector(IBindingSet[] leftSolutions,
IVariable<?>[] joinVars,
IVariable<?>[] selectVars,
boolean ignoreUnboundVariables,
AtomicInteger vectorSize)
Vector a chunk of solutions.
|
Constructor and Description |
---|
JVMDistinctFilter(IVariable<?>[] vars,
int initialCapacity,
float loadFactor,
int concurrencyLevel) |
JVMHashIndex(IVariable<?>[] keyVars,
boolean indexSolutionsHavingUnboundJoinVars,
Map<JVMHashIndex.Key,JVMHashIndex.Bucket> map) |
Modifier and Type | Method and Description |
---|---|
Set<IVariable<?>> |
PartitionedJoinGroup.getJoinGraphVars()
Deprecated.
The set of variables bound by the non-optional predicates (either the
head plan or the join graph).
|
Modifier and Type | Method and Description |
---|---|
static IConstraint[][] |
PartitionedJoinGroup.getJoinGraphConstraints(IPredicate<?>[] path,
IConstraint[] joinGraphConstraints,
IVariable<?>[] knownBoundVars,
boolean pathIsComplete)
Deprecated.
Given a join path, return the set of constraints to be associated with
each join in that join path.
|
Modifier and Type | Method and Description |
---|---|
Set<IVariable<?>> |
JoinGraph.getDoneSet()
Return the set of variables that are known to have already been
materialized at the point in the overall query plan where the RTO is
being executed.
|
Modifier and Type | Method and Description |
---|---|
IVariable<?> |
VariableUnificationOp.getTargetVar() |
IVariable<?> |
VariableUnificationOp.getTmpVar() |
IVariable<?> |
DataSetJoin.getVar() |
IVariable<?>[] |
MockTermResolverOp.getVars()
Return the variables for which mocked IVs are resolved.
|
protected IVariable<?>[] |
VariableUnificationOp.getVars() |
IVariable<?>[] |
ChunkedMaterializationOp.getVars()
Return the variables to be materialized.
|
Constructor and Description |
---|
ChunkedMaterializationIterator(IVariable<?>[] vars,
LexiconRelation lex,
boolean materializeInlineIVs,
ICloseableIterator<IBindingSet[]> src) |
ChunkedMaterializationOp(BOp[] args,
IVariable<?>[] vars,
String namespace,
long timestamp) |
MockTermResolverOp(BOp[] args,
IVariable<?>[] vars,
String namespace,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
protected static IV |
AbstractAddRemoveStatementsOp.getIV(IVariable<?> var,
IBindingSet bset,
boolean required)
Return the bound value for the variable.
|
Modifier and Type | Method and Description |
---|---|
IVariable<?>[] |
DropOp.getDropVars() |
IVariable<?>[] |
ProjectionOp.getVariables() |
IVariable<?>[] |
JVMDistinctBindingSetsOp.getVariables() |
IVariable<?> |
AbstractAggregationTestCase.MockVariableFactory.var() |
IVariable<?> |
GroupByRewriter.var()
Return a new anonymous variable (this is overridden by some unit tests in
order to have predictable variable names).
|
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<IAggregate<?>,IVariable<?>> |
IGroupByRewriteState.getAggExpr()
The set of all unique
IAggregate expressions paired with
anonymous variables. |
LinkedHashMap<IAggregate<?>,IVariable<?>> |
GroupByRewriter.getAggExpr()
The set of all unique
IAggregate expressions with Bind s
onto anonymous variables. |
LinkedHashSet<IVariable<?>> |
GroupByState.getColumnVars() |
LinkedHashSet<IVariable<?>> |
IGroupByState.getColumnVars()
Variables for which we will need column projections.
|
LinkedHashSet<IVariable<?>> |
GroupByState.getGroupByVars() |
LinkedHashSet<IVariable<?>> |
IGroupByState.getGroupByVars()
Top-level variables in the GROUP_BY clause in the order in which they
were declared.
|
LinkedHashSet<IVariable<?>> |
GroupByState.getSelectVars() |
LinkedHashSet<IVariable<?>> |
IGroupByState.getSelectVars()
Top-level variables in the SELECT clause in the order in which they were
declared.
|
Modifier and Type | Method and Description |
---|---|
static IConstraint |
GroupByRewriter.rewrite(IConstraint e,
IVariableFactory f,
LinkedHashMap<IAggregate<?>,IVariable<?>> aggExpr)
Rewrite an
IConstraint . |
static IValueExpression<?> |
GroupByRewriter.rewrite(IValueExpression<?> e,
IVariableFactory f,
LinkedHashMap<IAggregate<?>,IVariable<?>> aggExpr)
Rewrite an
IValueExpression from a SELECT or HAVING clause. |
Modifier and Type | Method and Description |
---|---|
List<org.openrdf.model.Value> |
BinderBase.bind(org.openrdf.model.ValueFactory vf,
IGASState<VS,ES,ST> state,
org.openrdf.model.Value u,
IVariable<?>[] outVars,
IBindingSet bs)
|
List<org.openrdf.model.Value> |
IBinder.bind(org.openrdf.model.ValueFactory vf,
IGASState<VS,ES,ST> state,
org.openrdf.model.Value u,
IVariable<?>[] outVars,
IBindingSet bs)
New multi-binding strategy allows binders to bind multiple values to
a given output variable (multiplying the number of solutions by the
number of bindings).
|
Modifier and Type | Method and Description |
---|---|
IVariable<E> |
ConditionalBind.getVar()
Return the variable which will be bound to the result of evaluating the
associated value expression.
|
Constructor and Description |
---|
ConditionalBind(IVariable<E> var,
IValueExpression<E> expr,
boolean projection) |
IsBoundBOp(IVariable<IV> x) |
IsInlineBOp(IVariable<IV> x,
boolean inline) |
IsMaterializedBOp(IVariable<IV> x,
boolean materialized) |
Modifier and Type | Field and Description |
---|---|
protected LinkedHashSet<IVariable<?>> |
IVBindingSetEncoderWithIVCache.ivCacheSchema
Deprecated.
The set of variables for which materialized
IV s have been
observed. |
Modifier and Type | Method and Description |
---|---|
static LexPredicate |
LexPredicate.forwardInstance(String relationName,
long timestamp,
IVariableOrConstant<BigdataValue> term,
IVariable<IV> var)
Simplified forward lookup ctor.
|
static LexPredicate |
LexPredicate.reverseInstance(String relationName,
long timestamp,
IVariable<BigdataValue> var,
IVariableOrConstant<IV> term)
Simplified reverse lookup ctor.
|
Constructor and Description |
---|
BindingSetSortKeyBuilder(IKeyBuilder keyBuilder,
IVariable[] vars) |
Constructor and Description |
---|
AbstractRuleDistinctTermScan.DistinctTermScan(IRule rule,
IJoinNexus joinNexus,
IBuffer<ISolution[]> buffer,
IVariable<IV> h,
SPOKeyOrder keyOrder) |
MatchRule(String relationName,
Vocabulary vocab,
IVariable<IV> lit,
IConstant<IV>[] preds,
IConstant<IV> cls) |
RejectAnythingSameAsItself(IVariable<Long> s,
IVariable<Long> p,
IVariable<Long> o,
IConstant<Long> owlSameAs) |
RejectAnythingSameAsItself(IVariable<Long> s,
IVariable<Long> p,
IVariable<Long> o,
IConstant<Long> owlSameAs) |
RejectAnythingSameAsItself(IVariable<Long> s,
IVariable<Long> p,
IVariable<Long> o,
IConstant<Long> owlSameAs) |
Modifier and Type | Method and Description |
---|---|
Set<IVariable<?>> |
RDRHistoryServiceFactory.getDesiredBound(ServiceNode serviceNode) |
Set<IVariable<?>> |
RDRHistoryServiceFactory.getRequiredBound(ServiceNode serviceNode) |
Modifier and Type | Field and Description |
---|---|
protected Set<IVariable> |
AbstractSolutionSetStatsTestCase.MySolutionStats.alwaysBound
The set of variables which are bound in ALL solutions.
|
protected Map<IVariable,IConstant> |
AbstractSolutionSetStatsTestCase.MySolutionStats.constants
The set of variables which are effective constants (they are bound in
every solution and always to the same value) together with their constant
bindings.
|
protected Set<IVariable<?>> |
SolutionSetStatserator.currentVars |
protected static Map<IVariable,IConstant> |
AbstractSolutionSetStatsTestCase.emptyMap
Typed empty map.
|
protected static Set<IVariable> |
AbstractSolutionSetStatsTestCase.emptySet
Typed empty set.
|
Set<IVariable<?>> |
JoinSetUtil.eventuallyBoundVars
The set of variables which are bound by the time the last required join
is done.
|
protected Map<IVariable<?>,IConstant<?>> |
SolutionSetStatserator.firstBoundValue
A map from the variable to the first bound value for that variable.
|
Set<IVariable<?>> |
JoinSetUtil.VertexJoinSet.joinvars
The set of variables bound by at least one join in the join set.
|
Set<IVariable<?>> |
JoinSetUtil.knownBound
The variables known to be bound on entry to the group.
|
protected Set<IVariable> |
AbstractSolutionSetStatsTestCase.MySolutionStats.materialized
The set of variables whose bound values always have their
IVCache assertion set (if the variable is bound). |
protected Set<IVariable> |
AbstractSolutionSetStatsTestCase.MySolutionStats.notAlwaysBound
The set of variables which are NOT bound in at least one solution (e.g.,
MAYBE bound semantics).
|
protected Set<IVariable<?>> |
SolutionSetStatserator.notAlwaysBound
The set of variables which are NOT bound in at least one solution (e.g.,
MAYBE bound semantics).
|
protected Set<IVariable<?>> |
SolutionSetStatserator.notBoundThisSolution |
protected Set<IVariable<?>> |
SolutionSetStatserator.notConstant
The set of variables which have been proven to not be effective
constants.
|
protected Set<IVariable<?>> |
SolutionSetStatserator.notMaterialized
The set of variables whose
IVCache association is NOT set is at
least one solution in which the variable is bound. |
protected Set<IVariable> |
AbstractSolutionSetStatsTestCase.MySolutionStats.usedVars
The set of variables observed across all solutions.
|
protected Set<IVariable<?>> |
SolutionSetStatserator.usedVars
The set of variables observed across all solutions.
|
Modifier and Type | Method and Description |
---|---|
static IVariable[] |
ASTUtil.convert(VarNode[] a)
|
IVariable<?> |
SubqueryRoot.getAskVar() |
IVariable<?>[] |
GraphPatternGroup.getJoinVars()
The join variables for the group.
|
IVariable<?>[] |
GraphPatternGroup.getProjectInVars()
The variables that should be projected into the group.
|
IVariable[] |
ProjectionNode.getProjectionVars()
Return the projected variables.
|
IVariable<IV> |
VarNode.getValueExpression()
Strengthen return type.
|
IVariable<IV> |
AssignmentNode.getVar()
The variable onto which the assignment is bound (as an
IVariable ). |
Modifier and Type | Method and Description |
---|---|
protected Map<IVariable,IConstant> |
AbstractSolutionSetStatsTestCase.asMap(IVariable[] vars,
IConstant[] vals) |
protected Set<IVariable> |
AbstractSolutionSetStatsTestCase.asSet(IVariable... vars)
Turn an array of variables into a
Set of variables. |
protected static Set<IVariable<?>> |
AbstractASTEvaluationTestCase.asSet(IVariable<?>[] vars) |
protected static Set<IVariable<?>> |
AbstractASTEvaluationTestCase.asSet(String[] vars) |
Set<IVariable<?>> |
StaticAnalysis.getAfterVars(IGroupMemberNode node,
Set<IVariable<?>> vars)
Return any variables which are used after the given node in the current
ordering of its parent
JoinGroupNode but DOES NOT consider the
parent or the PROJECTION for the query in which this group appears. |
Set<IVariable<?>> |
AbstractSolutionSetStatsTestCase.MySolutionStats.getAlwaysBound() |
Set<IVariable<?>> |
SolutionSetStats.getAlwaysBound()
Deprecated.
|
Set<IVariable<?>> |
EmptySolutionSetStats.getAlwaysBound() |
Set<IVariable<?>> |
CompiledSolutionSetStats.getAlwaysBound() |
Set<IVariable<?>> |
ISolutionSetStats.getAlwaysBound()
Return the subset of the variables which are bound in all solutions.
|
Map<IVariable<?>,IConstant<?>> |
AbstractSolutionSetStatsTestCase.MySolutionStats.getConstants() |
Map<IVariable<?>,IConstant<?>> |
SolutionSetStats.getConstants()
Deprecated.
|
Map<IVariable<?>,IConstant<?>> |
EmptySolutionSetStats.getConstants() |
Map<IVariable<?>,IConstant<?>> |
CompiledSolutionSetStats.getConstants() |
Map<IVariable<?>,IConstant<?>> |
ISolutionSetStats.getConstants()
The set of variables which are effective constants (they are bound in
every solution and always to the same value) together with their constant
bindings.
|
Set<IVariable<?>> |
IValueExpressionMetadata.getConsumedVars()
Return the set of variables that will be used by this constraint to
determine which solutions will continue on through the pipeline and which
will be filtered out.
|
Set<IVariable<?>> |
GroupMemberValueExpressionNodeBase.getConsumedVars() |
LinkedHashSet<IVariable<?>> |
BindingsClause.getDeclaredVariables()
Return the ordered set of declared variables for the BINDINGS clause.
|
Set<IVariable<?>> |
StaticAnalysis.getDefinitelyIncomingBindings(IGroupMemberNode node,
Set<IVariable<?>> vars)
Return the set of variables which MUST be bound coming into this group
during top-down, left-to-right evaluation.
|
Set<IVariable<?>> |
GroupNodeVarBindingInfo.getDefinitelyProduced() |
Set<IVariable<?>> |
ArbitraryLengthPathNode.getDefinitelyProducedBindings()
Return the variables bound by the path - i.e.
|
LinkedHashSet<IVariable<?>> |
BindingsClause.getDefinitelyProducedBindings()
Return the ordered set of variables that will definitely be bound by
this bindings/values clause.
|
Set<IVariable<?>> |
StaticAnalysis.getDefinitelyProducedBindings(IBindingProducerNode node,
Set<IVariable<?>> vars,
boolean recursive)
Return the set of variables which MUST be bound for solutions after the
evaluation of this group.
|
abstract Set<IVariable<?>> |
StaticAnalysis_CanJoin.getDefinitelyProducedBindings(IBindingProducerNode node,
Set<IVariable<?>> vars,
boolean recursive)
Return the set of variables which MUST be bound for solutions after the
evaluation of this group.
|
Set<IVariable<?>> |
StaticAnalysis.getDefinitelyProducedBindings(QueryBase queryBase)
Report "MUST" bound bindings projected by the query.
|
Set<IVariable<?>> |
StaticAnalysis.getDefinitelyProducedBindings(ServiceNode node)
Report "MUST" bound bindings projected by the SERVICE.
|
Set<IVariable<?>> |
StaticAnalysis.getDefinitelyProducedBindingsAndFilterVariables(IGroupNode<? extends IGroupMemberNode> group,
Set<IVariable<?>> vars)
Collect all variables appearing in the group.
|
Set<IVariable<?>> |
GroupNodeVarBindingInfo.getDesiredBound() |
Set<IVariable<?>> |
NamedSubqueryInclude.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
AbstractStatementContainer.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
SubqueryBase.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
GraphManagement.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
StatementPatternNode.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
FilterNode.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
AbstractFromToGraphManagement.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
ArbitraryLengthPathNode.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
UnionNode.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
IVariableBindingRequirements.getDesiredBound(StaticAnalysis sa)
Get variables that are not required to be bound, but desired in the
sense that we want them to be bound when evaluating the construct.
|
Set<IVariable<?>> |
Update.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
PropertyPathNode.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
BindingsClause.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
UpdateRoot.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
AssignmentNode.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
JoinGroupNode.getDesiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
ZeroLengthPathNode.getDesiredBound(StaticAnalysis sa)
Deprecated.
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(BindingsClause bc,
ISolutionSetStats stats,
Set<IVariable<?>> vars)
Return the join variables for a VALUES clause (embedded only - not
top-level).
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(NamedSubqueryInclude nsi,
String solutionSet,
Set<IVariable<?>> vars)
Return the join variables for an INCLUDE of a pre-existing named solution
set.
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(NamedSubqueryRoot aNamedSubquery,
NamedSubqueryInclude anInclude,
Set<IVariable<?>> vars)
Identify the join variables for the specified INCLUDE for the position
within the query in which it appears.
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(ServiceNode serviceNode,
Set<IVariable<?>> vars)
Return the join variables for a SERVICE.
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(SubqueryRoot subquery,
Set<IVariable<?>> vars)
Identify the join variables for the specified subquery for the position
within the query in which it appears.
|
Set<IVariable<?>> |
NamedSubqueryInclude.getJoinVarSet()
Return the ordered set of join variables.
|
Set<IVariable<?>> |
AbstractSolutionSetStatsTestCase.MySolutionStats.getMaterialized() |
Set<IVariable<?>> |
SolutionSetStats.getMaterialized()
Deprecated.
|
Set<IVariable<?>> |
EmptySolutionSetStats.getMaterialized() |
Set<IVariable<?>> |
CompiledSolutionSetStats.getMaterialized() |
Set<IVariable<?>> |
ISolutionSetStats.getMaterialized()
Return the subset of the variables which are materialized in all
solutions in which they appear (the variables do not have to be bound in
every solution, but if they are bound then their
IVCache
association is always set). |
Set<IVariable<?>> |
StaticAnalysis.getMaybeIncomingBindings(IGroupMemberNode node,
Set<IVariable<?>> vars)
Return the set of variables which MIGHT be bound coming into this group
during top-down, left-to-right evaluation.
|
Set<IVariable<?>> |
GroupNodeVarBindingInfo.getMaybeProduced() |
Set<IVariable<?>> |
ArbitraryLengthPathNode.getMaybeProducedBindings()
Return the variables bound by the path - i.e.
|
Set<IVariable<?>> |
StaticAnalysis.getMaybeProducedBindings(IBindingProducerNode node,
Set<IVariable<?>> vars,
boolean recursive)
Return the set of variables which MUST or MIGHT be bound after the
evaluation of this join group.
|
Set<IVariable<?>> |
StaticAnalysis.getMaybeProducedBindings(QueryBase node)
Report the "MUST" and "MAYBE" bound bindings projected by the query.
|
Set<IVariable<?>> |
StaticAnalysis.getMaybeProducedBindings(ServiceNode node)
Report the "MUST" and "MAYBE" bound variables projected by the service.
|
Set<IVariable<?>> |
AbstractSolutionSetStatsTestCase.MySolutionStats.getNotAlwaysBound() |
Set<IVariable<?>> |
SolutionSetStats.getNotAlwaysBound()
Deprecated.
|
Set<IVariable<?>> |
EmptySolutionSetStats.getNotAlwaysBound() |
Set<IVariable<?>> |
CompiledSolutionSetStats.getNotAlwaysBound() |
Set<IVariable<?>> |
ISolutionSetStats.getNotAlwaysBound()
Return the subset of the variables which are NOT bound in all solutions.
|
Set<IVariable<?>> |
StatementPatternNode.getProducedBindings()
Return the variables used by the predicate - i.e.
|
Set<IVariable<?>> |
PropertyPathNode.getProducedBindings()
Return the variables used by the predicate - i.e.
|
Set<IVariable<?>> |
ZeroLengthPathNode.getProducedBindings()
Deprecated.
Return the variables used by the path - i.e.
|
Set<IVariable<?>> |
StaticAnalysis.getProjectedVars(IGroupMemberNode proxy,
GraphPatternGroup<?> groupToLift,
QueryBase query,
Set<IVariable<?>> exogenousVars,
Set<IVariable<?>> projectedVars)
Return the set of variables which must be projected if the group is to be
converted into a sub-query.
|
Set<IVariable<?>> |
QueryBase.getProjectedVars(Set<IVariable<?>> vars) |
Set<IVariable<?>> |
QuadsDataOrNamedSolutionSet.getProjectedVars(Set<IVariable<?>> vars) |
Set<IVariable<?>> |
IProjectionDecl.getProjectedVars(Set<IVariable<?>> vars)
Return the set of variables projected out of this query (this is a NOP if
there is no
ProjectionNode for the query, which can happen for an
ASK query). |
Set<IVariable<?>> |
ProjectionNode.getProjectionVars(Set<IVariable<?>> vars)
Return the projected variables.
|
Set<IVariable<?>> |
GroupNodeVarBindingInfo.getRequiredBound() |
Set<IVariable<?>> |
NamedSubqueryInclude.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
AbstractStatementContainer.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
SubqueryBase.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
GraphManagement.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
StatementPatternNode.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
FilterNode.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
AbstractFromToGraphManagement.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
ArbitraryLengthPathNode.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
UnionNode.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
IVariableBindingRequirements.getRequiredBound(StaticAnalysis sa)
Return the variables used in the node that *must* be bound prior to
evaluating the node.
|
Set<IVariable<?>> |
Update.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
PropertyPathNode.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
BindingsClause.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
UpdateRoot.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
AssignmentNode.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
JoinGroupNode.getRequiredBound(StaticAnalysis sa) |
Set<IVariable<?>> |
ZeroLengthPathNode.getRequiredBound(StaticAnalysis sa)
Deprecated.
|
Set<IVariable<?>> |
ProjectionNode.getSelectExprVars(Set<IVariable<?>> vars)
Collect the variables used by the SELECT EXPRESSIONS for this projection
node.
|
Set<IVariable<?>> |
QueryBase.getSelectExprVars(Set<IVariable<?>> vars)
Return the set of variables on which the
ProjectionNode for this
query depends (this is a NOP if there is no ProjectionNode for
the query, which can happen for an ASK query). |
Set<IVariable<?>> |
StaticAnalysisBase.getSpannedVariables(BOp op,
boolean filters,
Set<IVariable<?>> varSet)
Return the distinct variables in the operator tree.
|
Set<IVariable<?>> |
StaticAnalysisBase.getSpannedVariables(BOp op,
Set<IVariable<?>> varSet)
Return the distinct variables in the operator tree, including on those on
annotations attached to operators.
|
static Set<IVariable<?>> |
StaticAnalysisBase.getSPOVariables(StatementPatternNode sp)
Return any variables appearing in the Subject, Predicate, or Object
position (the Context position is ignored).
|
Set<IVariable<?>> |
AbstractSolutionSetStatsTestCase.MySolutionStats.getUsedVars() |
Set<IVariable<?>> |
SolutionSetStats.getUsedVars()
Deprecated.
|
Set<IVariable<?>> |
EmptySolutionSetStats.getUsedVars() |
Set<IVariable<?>> |
CompiledSolutionSetStats.getUsedVars() |
Set<IVariable<?>> |
ArbitraryLengthPathNode.getUsedVars()
Return the set of variables used by this ALP node (statement pattern
terms and inside filters).
|
Set<IVariable<?>> |
ISolutionSetStats.getUsedVars()
Return the set of variables which in at least one solution.
|
Set<IVariable<?>> |
StaticAnalysis.getVarsInBindingSet(List<IBindingSet> bss)
Extract the set of variables contained in a binding set.
|
Set<IVariable<IV>> |
ComputedMaterializationRequirement.getVarsToMaterialize() |
Set<IVariable<?>> |
GroupNodeVarBindingInfo.leftToBeBound(Set<IVariable<?>> knownBound)
Get variables that remain to be bound, assuming that the definitely
incoming variables plus the variables passed as parameter are bound
already.
|
Modifier and Type | Method and Description |
---|---|
protected Map<IVariable,IConstant> |
AbstractSolutionSetStatsTestCase.asMap(IVariable[] vars,
IConstant[] vals) |
protected Set<IVariable> |
AbstractSolutionSetStatsTestCase.asSet(IVariable... vars)
Turn an array of variables into a
Set of variables. |
protected static Set<IVariable<?>> |
AbstractASTEvaluationTestCase.asSet(IVariable<?>[] vars) |
static VarNode[] |
ASTUtil.convert(IVariable[] a)
|
boolean |
ProjectionNode.excludeFromProjection(IVariable<?> var)
Checks if the variable is "blacklisted" to be excluded from
projection variables.
|
void |
SubqueryRoot.setAskVar(IVariable<?> askVar) |
void |
GraphPatternGroup.setJoinVars(IVariable<?>[] joinVars) |
void |
GraphPatternGroup.setProjectInVars(IVariable<?>[] projectInVars) |
Modifier and Type | Method and Description |
---|---|
protected void |
StaticAnalysisBase.addAll(Set<IVariable<?>> bindings,
IGroupMemberNode op)
Add all variables spanned by the operator.
|
static INeedsMaterialization.Requirement |
StaticAnalysis.gatherVarsToMaterialize(BOp c,
Set<IVariable<IV>> terms)
Static helper used to determine materialization requirements.
|
static INeedsMaterialization.Requirement |
StaticAnalysis.gatherVarsToMaterialize(BOp c,
Set<IVariable<IV>> terms,
boolean includeVarsInAnnotations)
Static helper used to determine materialization requirements.
|
static INeedsMaterialization.Requirement |
StaticAnalysis.gatherVarsToMaterialize(BOp c,
Set<IVariable<IV>> terms,
Map<IVariable<?>,IValueExpression<?>> varMap)
Static helper used to determine materialization requirements.
|
static INeedsMaterialization.Requirement |
StaticAnalysis.gatherVarsToMaterialize(BOp c,
Set<IVariable<IV>> terms,
Map<IVariable<?>,IValueExpression<?>> varMap)
Static helper used to determine materialization requirements.
|
static INeedsMaterialization.Requirement |
StaticAnalysis.gatherVarsToMaterialize(BOp c,
Set<IVariable<IV>> terms,
Map<IVariable<?>,IValueExpression<?>> varMap,
boolean includeVarsInAnnotations)
Static helper used to determine materialization requirements.
|
static INeedsMaterialization.Requirement |
StaticAnalysis.gatherVarsToMaterialize(BOp c,
Set<IVariable<IV>> terms,
Map<IVariable<?>,IValueExpression<?>> varMap,
boolean includeVarsInAnnotations)
Static helper used to determine materialization requirements.
|
Set<IVariable<?>> |
StaticAnalysis.getAfterVars(IGroupMemberNode node,
Set<IVariable<?>> vars)
Return any variables which are used after the given node in the current
ordering of its parent
JoinGroupNode but DOES NOT consider the
parent or the PROJECTION for the query in which this group appears. |
Set<IVariable<?>> |
StaticAnalysis.getDefinitelyIncomingBindings(IGroupMemberNode node,
Set<IVariable<?>> vars)
Return the set of variables which MUST be bound coming into this group
during top-down, left-to-right evaluation.
|
Set<IVariable<?>> |
StaticAnalysis.getDefinitelyProducedBindings(IBindingProducerNode node,
Set<IVariable<?>> vars,
boolean recursive)
Return the set of variables which MUST be bound for solutions after the
evaluation of this group.
|
abstract Set<IVariable<?>> |
StaticAnalysis_CanJoin.getDefinitelyProducedBindings(IBindingProducerNode node,
Set<IVariable<?>> vars,
boolean recursive)
Return the set of variables which MUST be bound for solutions after the
evaluation of this group.
|
Set<IVariable<?>> |
StaticAnalysis.getDefinitelyProducedBindingsAndFilterVariables(IGroupNode<? extends IGroupMemberNode> group,
Set<IVariable<?>> vars)
Collect all variables appearing in the group.
|
FilterNode[][] |
StaticAnalysis_CanJoin.getJoinGraphConstraints(IJoinNode[] path,
FilterNode[] joinGraphConstraints,
Set<IVariable<?>> boundVars,
boolean pathIsComplete)
Given a join path, return the set of constraints to be associated with
each join in that join path.
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(BindingsClause bc,
ISolutionSetStats stats,
Set<IVariable<?>> vars)
Return the join variables for a VALUES clause (embedded only - not
top-level).
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(NamedSubqueryInclude nsi,
String solutionSet,
Set<IVariable<?>> vars)
Return the join variables for an INCLUDE of a pre-existing named solution
set.
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(NamedSubqueryRoot aNamedSubquery,
NamedSubqueryInclude anInclude,
Set<IVariable<?>> vars)
Identify the join variables for the specified INCLUDE for the position
within the query in which it appears.
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(ServiceNode serviceNode,
Set<IVariable<?>> vars)
Return the join variables for a SERVICE.
|
Set<IVariable<?>> |
StaticAnalysis.getJoinVars(SubqueryRoot subquery,
Set<IVariable<?>> vars)
Identify the join variables for the specified subquery for the position
within the query in which it appears.
|
Set<IVariable<?>> |
StaticAnalysis.getMaybeIncomingBindings(IGroupMemberNode node,
Set<IVariable<?>> vars)
Return the set of variables which MIGHT be bound coming into this group
during top-down, left-to-right evaluation.
|
Set<IVariable<?>> |
StaticAnalysis.getMaybeProducedBindings(IBindingProducerNode node,
Set<IVariable<?>> vars,
boolean recursive)
Return the set of variables which MUST or MIGHT be bound after the
evaluation of this join group.
|
Set<IVariable<?>> |
StaticAnalysis.getProjectedVars(IGroupMemberNode proxy,
GraphPatternGroup<?> groupToLift,
QueryBase query,
Set<IVariable<?>> exogenousVars,
Set<IVariable<?>> projectedVars)
Return the set of variables which must be projected if the group is to be
converted into a sub-query.
|
Set<IVariable<?>> |
StaticAnalysis.getProjectedVars(IGroupMemberNode proxy,
GraphPatternGroup<?> groupToLift,
QueryBase query,
Set<IVariable<?>> exogenousVars,
Set<IVariable<?>> projectedVars)
Return the set of variables which must be projected if the group is to be
converted into a sub-query.
|
Set<IVariable<?>> |
QueryBase.getProjectedVars(Set<IVariable<?>> vars) |
Set<IVariable<?>> |
QuadsDataOrNamedSolutionSet.getProjectedVars(Set<IVariable<?>> vars) |
Set<IVariable<?>> |
IProjectionDecl.getProjectedVars(Set<IVariable<?>> vars)
Return the set of variables projected out of this query (this is a NOP if
there is no
ProjectionNode for the query, which can happen for an
ASK query). |
Set<IVariable<?>> |
ProjectionNode.getProjectionVars(Set<IVariable<?>> vars)
Return the projected variables.
|
Set<IVariable<?>> |
ProjectionNode.getSelectExprVars(Set<IVariable<?>> vars)
Collect the variables used by the SELECT EXPRESSIONS for this projection
node.
|
Set<IVariable<?>> |
QueryBase.getSelectExprVars(Set<IVariable<?>> vars)
Return the set of variables on which the
ProjectionNode for this
query depends (this is a NOP if there is no ProjectionNode for
the query, which can happen for an ASK query). |
Set<IVariable<?>> |
StaticAnalysisBase.getSpannedVariables(BOp op,
boolean filters,
Set<IVariable<?>> varSet)
Return the distinct variables in the operator tree.
|
Set<IVariable<?>> |
StaticAnalysisBase.getSpannedVariables(BOp op,
Set<IVariable<?>> varSet)
Return the distinct variables in the operator tree, including on those on
annotations attached to operators.
|
boolean |
StaticAnalysisBase.isFullyBound(FilterNode f,
Set<IVariable<?>> vars)
Return
true if the FilterNode is fully bound for the
given variables. |
Set<IVariable<?>> |
GroupNodeVarBindingInfo.leftToBeBound(Set<IVariable<?>> knownBound)
Get variables that remain to be bound, assuming that the definitely
incoming variables plus the variables passed as parameter are bound
already.
|
void |
BindingsClause.setDeclaredVariables(LinkedHashSet<IVariable<?>> declaredVars) |
void |
ProjectionNode.setVarsToExcludeFromProjection(Set<IVariable<?>> vars)
Makes a copy of vars the (new) black list for variables that are
not to be treated as projection variables.
|
Constructor and Description |
---|
VarNode(IVariable<IV> var) |
Constructor and Description |
---|
AbstractSolutionSetStatsTestCase.MySolutionStats(long nsolutions,
Set<IVariable> usedVars,
Set<IVariable> notAlwaysBound,
Set<IVariable> alwaysBound,
Set<IVariable> materialized,
Map<IVariable,IConstant> constants) |
AbstractSolutionSetStatsTestCase.MySolutionStats(long nsolutions,
Set<IVariable> usedVars,
Set<IVariable> notAlwaysBound,
Set<IVariable> alwaysBound,
Set<IVariable> materialized,
Map<IVariable,IConstant> constants) |
AbstractSolutionSetStatsTestCase.MySolutionStats(long nsolutions,
Set<IVariable> usedVars,
Set<IVariable> notAlwaysBound,
Set<IVariable> alwaysBound,
Set<IVariable> materialized,
Map<IVariable,IConstant> constants) |
AbstractSolutionSetStatsTestCase.MySolutionStats(long nsolutions,
Set<IVariable> usedVars,
Set<IVariable> notAlwaysBound,
Set<IVariable> alwaysBound,
Set<IVariable> materialized,
Map<IVariable,IConstant> constants) |
AbstractSolutionSetStatsTestCase.MySolutionStats(long nsolutions,
Set<IVariable> usedVars,
Set<IVariable> notAlwaysBound,
Set<IVariable> alwaysBound,
Set<IVariable> materialized,
Map<IVariable,IConstant> constants) |
BindingsClause(LinkedHashSet<IVariable<?>> declaredVars,
List<IBindingSet> bindingSets) |
CompiledSolutionSetStats(long nsolutions,
Set<IVariable<?>> usedVars,
Set<IVariable<?>> alwaysBound,
Set<IVariable<?>> notAlwaysBound,
Set<IVariable<?>> materialized,
Map<IVariable<?>,IConstant<?>> constants)
Constructor exposes unmodifable versions of its arguments.
|
CompiledSolutionSetStats(long nsolutions,
Set<IVariable<?>> usedVars,
Set<IVariable<?>> alwaysBound,
Set<IVariable<?>> notAlwaysBound,
Set<IVariable<?>> materialized,
Map<IVariable<?>,IConstant<?>> constants)
Constructor exposes unmodifable versions of its arguments.
|
CompiledSolutionSetStats(long nsolutions,
Set<IVariable<?>> usedVars,
Set<IVariable<?>> alwaysBound,
Set<IVariable<?>> notAlwaysBound,
Set<IVariable<?>> materialized,
Map<IVariable<?>,IConstant<?>> constants)
Constructor exposes unmodifable versions of its arguments.
|
CompiledSolutionSetStats(long nsolutions,
Set<IVariable<?>> usedVars,
Set<IVariable<?>> alwaysBound,
Set<IVariable<?>> notAlwaysBound,
Set<IVariable<?>> materialized,
Map<IVariable<?>,IConstant<?>> constants)
Constructor exposes unmodifable versions of its arguments.
|
CompiledSolutionSetStats(long nsolutions,
Set<IVariable<?>> usedVars,
Set<IVariable<?>> alwaysBound,
Set<IVariable<?>> notAlwaysBound,
Set<IVariable<?>> materialized,
Map<IVariable<?>,IConstant<?>> constants)
Constructor exposes unmodifable versions of its arguments.
|
ComputedMaterializationRequirement(INeedsMaterialization.Requirement requirement,
Set<IVariable<IV>> varsToMaterialize) |
JoinSetUtil.VertexJoinSet(Set<Integer> vertices,
Set<IVariable<?>> joinvars) |
JoinSetUtil(StaticAnalysis sa,
Set<IVariable<?>> knownBound,
GraphPatternGroup<IGroupMemberNode> group) |
Constructor and Description |
---|
DescribeBindingsCollector(Set<IVariable<?>> originalVars,
Set<BigdataValue> describedResources,
info.aduna.iteration.CloseableIteration<org.openrdf.query.BindingSet,org.openrdf.query.QueryEvaluationException> src) |
Modifier and Type | Method and Description |
---|---|
IVariable<IV> |
ServiceParams.getAsVar(org.openrdf.model.URI param)
Helper.
|
IVariable<IV> |
ServiceParams.getAsVar(org.openrdf.model.URI param,
IVariable<IV> defaultValue)
Helper.
|
Modifier and Type | Method and Description |
---|---|
Set<IVariable<?>> |
AbstractServiceFactoryBase.getDesiredBound(ServiceNode serviceNode)
Default implementation for method
ServiceFactory.getDesiredBound(ServiceNode) , allowing for
simple services where all variables used inside the service are
considered "outgoing". |
Set<IVariable<?>> |
CustomServiceFactoryBase.getDesiredBound(ServiceNode serviceNode)
Default implementation for method
ServiceFactory.getDesiredBound(ServiceNode) , allowing for
simple services where all variables used inside the service are
considered "outgoing". |
Set<IVariable<?>> |
IEvaluationContext.getGloballyScopedVariables()
Returns all the variables with a global scope.
|
Set<IVariable<?>> |
AST2BOpContext.getGloballyScopedVariables() |
Set<IVariable<?>> |
GeoSpatialServiceFactory.getRequiredBound(ServiceNode serviceNode) |
Set<IVariable<?>> |
AbstractServiceFactoryBase.getRequiredBound(ServiceNode serviceNode)
Default implementation for method
ServiceFactory.getRequiredBound(ServiceNode) , allowing for
simple services where all variables used inside the service are
considered "outgoing". |
Set<IVariable<?>> |
CustomServiceFactoryBase.getRequiredBound(ServiceNode serviceNode)
Default implementation for method
ServiceFactory.getRequiredBound(ServiceNode) , allowing for
simple services where all variables used inside the service are
considered "outgoing". |
Modifier and Type | Method and Description |
---|---|
IVariable<IV> |
ServiceParams.getAsVar(org.openrdf.model.URI param,
IVariable<IV> defaultValue)
Helper.
|
Modifier and Type | Method and Description |
---|---|
protected static PipelineOp |
AST2BOpFilters.addChunkedMaterializationStep(PipelineOp left,
Set<IVariable<IV>> vars,
boolean materializeInlineIvs,
Long cutoffLimit,
Properties queryHints,
AST2BOpContext ctx)
Use a pipeline operator which uses the chunked materialization pattern
for solution sets.
|
protected static PipelineOp |
AST2BOpFilters.addMaterializationSteps1(PipelineOp left,
int rightId,
IValueExpression<IV> ve,
Set<IVariable<IV>> vars,
Properties queryHints,
AST2BOpContext ctx)
If the value expression that needs the materialized variables can run
without a
NotMaterializedException then just route to the
rightId (around the rest of the materialization pipeline steps). |
protected static PipelineOp |
AST2BOpFilters.addMaterializationSteps2(PipelineOp left,
int rightId,
Set<IVariable<IV>> vars,
Properties queryHints,
AST2BOpContext ctx)
Adds a series of materialization steps to materialize terms needed
downstream.
|
protected static PipelineOp |
AST2BOpFilters.addMaterializationSteps3(PipelineOp left,
Set<IVariable<?>> doneSet,
Map<IConstraint,Set<IVariable<IV>>> needsMaterialization,
Properties queryHints,
AST2BOpContext ctx)
For each filter which requires materialization steps, add the
materializations steps to the pipeline and then add the filter to the
pipeline.
|
protected static PipelineOp |
AST2BOpFilters.addMaterializationSteps3(PipelineOp left,
Set<IVariable<?>> doneSet,
Map<IConstraint,Set<IVariable<IV>>> needsMaterialization,
Properties queryHints,
AST2BOpContext ctx)
For each filter which requires materialization steps, add the
materializations steps to the pipeline and then add the filter to the
pipeline.
|
protected static PipelineOp |
AST2BOpFilters.addNonConditionalMaterializationSteps(PipelineOp left,
Set<IVariable<?>> doneSet,
Map<IConstraint,Set<IVariable<IV>>> needsMaterialization,
Long cutoffLimit,
Properties queryHints,
AST2BOpContext ctx)
The RTO requires that we do not reorder solutions.
|
protected static PipelineOp |
AST2BOpFilters.addNonConditionalMaterializationSteps(PipelineOp left,
Set<IVariable<?>> doneSet,
Map<IConstraint,Set<IVariable<IV>>> needsMaterialization,
Long cutoffLimit,
Properties queryHints,
AST2BOpContext ctx)
The RTO requires that we do not reorder solutions.
|
PipelineOp |
IExternalAST2BOp.convertJoinGroup(PipelineOp left,
JoinGroupNode joinGroup,
Set<IVariable<?>> doneSet,
AtomicInteger start,
AST2BOpContext ctx)
Translate the given join group.
|
protected static PipelineOp |
AST2BOpRTO.convertRTOJoinGraph(PipelineOp left,
JoinGroupNode joinGroup,
Set<IVariable<?>> doneSet,
AST2BOpContext ctx,
AtomicInteger start)
Inspect the remainder of the join group.
|
protected static IConstraint[] |
AST2BOpFilters.getJoinConstraints(Collection<IConstraint> constraints,
Map<IConstraint,Set<IVariable<IV>>> needsMaterialization)
Partition the constraints for a join into those which can (or might) be
able to run attached to that join and those which must (or might) need to
materialize some variables before they can be evaluated.
|
protected static IConstraint[] |
AST2BOpFilters.getJoinConstraints2(Collection<IConstraint> constraints,
Map<IConstraint,Set<IVariable<IV>>> needsMaterialization,
boolean conditionalRouting)
Partition the constraints for a join into those which can (or might) be
able to run attached to that join and those which must (or might) need to
materialize some variables before they can be evaluated.
|
static PipelineOp |
AST2BOpJoins.join(PipelineOp left,
Predicate pred,
Set<IVariable<?>> doneSet,
Collection<IConstraint> constraints,
Long cutoffLimit,
Properties queryHints,
AST2BOpContext ctx)
Add a join for a statement pattern.
|
void |
IEvaluationContext.setGloballyScopedVariables(Set<IVariable<?>> globallyScopedVariables)
Sets the variables with global scope.
|
void |
AST2BOpContext.setGloballyScopedVariables(Set<IVariable<?>> globallyScopedVariables) |
Constructor and Description |
---|
GeoSpatialServiceFactory.GeoSpatialServiceCallConfiguration(GeoSpatialServiceFactory.GeoSpatialDefaults defaults,
GeoSpatialConfig geoSpatialConfig,
IVariable<?> searchVar,
Map<org.openrdf.model.URI,StatementPatternNode> sps) |
Constructor and Description |
---|
BottomUpSemanticsExplainHint(IVariable<?> original,
IVariable<?> renamed,
BOp explainHintASTBase) |
BottomUpSemanticsExplainHint(IVariable<?> original,
IVariable<?> renamed,
BOp explainHintASTBase) |
Modifier and Type | Method and Description |
---|---|
IVariable |
ASTStaticBindingsOptimizer.InlineTasks.getVar() |
protected IVariable<? extends IV> |
AbstractOptimizerTestCase.Helper.toValueExpression(VarNode v) |
Modifier and Type | Method and Description |
---|---|
Set<IVariable<?>> |
ASTJoinGroupPartition.getDefinitelyProduced() |
Map<IVariable<?>,List<IQueryNode>> |
ASTStaticBindingsOptimizer.VariableUsageInfo.getUsageMap()
Gets the map recoding all usages of all variables (internal data
structure maintained by the class).
|
Set<IVariable<?>> |
AbstractOptimizerTestCaseWithUtilityMethods.varSet(String... varNames) |
Modifier and Type | Method and Description |
---|---|
List<IQueryNode> |
ASTStaticBindingsOptimizer.VariableUsageInfo.getVarUsages(IVariable<?> var)
Returns the list of variable usages.
|
boolean |
ASTStaticBindingsOptimizer.VariableUsageInfo.varUsed(IVariable<?> var)
Returns true iff usage records for the var are available.
|
boolean |
ASTStaticBindingsOptimizer.VariableUsageInfo.varUsedInFilterOrAssignment(IVariable<?> var)
Returns true if a usage record for the given variable inside a FILTER
or BIND/VALUES node has been recorded.
|
Constructor and Description |
---|
ASTStaticBindingsOptimizer.InlineTasks(IVariable var,
IConstant<IV> val,
List<IQueryNode> nodes)
Construct an inline task
|
Constructor and Description |
---|
ASTJoinGroupPartitions(List<IGroupMemberNode> nodes,
GroupNodeVarBindingInfoMap bindingInfo,
Set<IVariable<?>> externallyKnownProduced)
Constructor, creating partitions for a list of
IGroupMemberNode
objects along OPTIONAL and MINUS nodes. |
Modifier and Type | Field and Description |
---|---|
protected Set<IVariable<?>> |
RemoteSparql11QueryBuilder.projectedVars
The distinct variables "projected" by the SERVICE group graph pattern.
|
Modifier and Type | Method and Description |
---|---|
Set<IVariable<?>> |
ServiceFactory.getDesiredBound(ServiceNode serviceNode)
Returns, for the given service node, the variables that are desired
to be bound prior to start executing the service.
|
Set<IVariable<?>> |
RemoteServiceFactoryImpl.getDesiredBound(ServiceNode serviceNode) |
Set<IVariable<?>> |
ServiceNode.getDesiredBound(StaticAnalysis sa) |
List<IVariable<IV>> |
MockIVReturningServiceCall.getMockVariables()
Returns the set of variables that are internally bound.
|
Set<IVariable<?>> |
ServiceNode.getProjectedVars() |
Set<IVariable<?>> |
ServiceFactory.getRequiredBound(ServiceNode serviceNode)
Returns, for the given service node, the variables that must be
bound prior to start executing the service.
|
Set<IVariable<?>> |
RemoteServiceFactoryImpl.getRequiredBound(ServiceNode serviceNode)
In order to be able to evaluate the SPARQL 1.1 remote service, the
endpoint URIs must be known.
|
Set<IVariable<?>> |
ServiceNode.getRequiredBound(StaticAnalysis sa) |
Modifier and Type | Method and Description |
---|---|
static org.openrdf.query.BindingSet |
ServiceCallUtility.bigdata2Openrdf(LexiconRelation lex,
Set<IVariable<?>> vars,
IBindingSet in)
Convert the
IBindingSet into an openrdf BindingSet . |
static org.openrdf.query.BindingSet[] |
ServiceCallUtility.convert(LexiconRelation lex,
Set<IVariable<?>> projectedVars,
IBindingSet[] in)
Convert
IBindingSet [] to openrdf BindingSet []. |
void |
ServiceNode.setProjectedVars(Set<IVariable<?>> projectedVars) |
Modifier and Type | Field and Description |
---|---|
protected IVariable |
Binding.var
The variable.
|
Modifier and Type | Method and Description |
---|---|
IVariable |
Binding.getVar()
Get the variable.
|
IVariable |
IBinding.getVar()
Get the variable.
|
IVariable<IV> |
SPOPredicate.sid()
The variable for the statement identifier (optional).
|
Modifier and Type | Method and Description |
---|---|
Iterator<IVariable> |
SPOStarJoin.getConstraintVariables()
Return an iterator over the constraint variables for this star join.
|
Constructor and Description |
---|
Binding(IVariable var,
IConstant val)
Construct a binding instance.
|
Constructor and Description |
---|
BigdataBindingSetResolverator(AbstractTripleStore db,
IChunkedOrderedIterator<IBindingSet> src,
UUID queryId,
IVariable[] required,
int chunkOfChunksCapacity,
int chunkCapacity,
long chunkTimeout,
int termsChunkSize,
int blobsChunkSize) |
Modifier and Type | Field and Description |
---|---|
protected IVariable |
Binding.var
The variable.
|
Modifier and Type | Method and Description |
---|---|
IVariable |
Binding.getVar()
Get the variable.
|
IVariable |
IBinding.getVar()
Get the variable.
|
Modifier and Type | Method and Description |
---|---|
Iterator<IVariable> |
IStarJoin.getConstraintVariables()
Deprecated.
Returns an iterator over the variables used in this star join's
constraints.
|
Iterator<IVariable> |
IRule.getRequiredVariables()
The required variables declared by the rule in no particular order.
|
Iterator<IVariable> |
Rule.getRequiredVariables() |
Set<IVariable<?>> |
IRule.getSharedVars(int index1,
int index2)
Return the variables in common for two
IPredicate s. |
Set<IVariable<?>> |
Rule.getSharedVars(int index1,
int index2) |
static Set<IVariable<?>> |
Rule.getSharedVars(IPredicate p1,
IPredicate p2)
Return the variables in common for two
IPredicate s. |
Iterator<IVariable> |
IRule.getVariables()
The variables declared by the rule in no particular order.
|
Iterator<IVariable> |
Rule.getVariables() |
Modifier and Type | Method and Description |
---|---|
boolean |
IRule.isDeclared(IVariable var)
Return
true iff the rule declares this variable. |
boolean |
Rule.isDeclared(IVariable var) |
Constructor and Description |
---|
Binding(IVariable var,
IConstant val)
Construct a binding instance.
|
Rule(String name,
IPredicate head,
IPredicate[] tail,
IQueryOptions queryOptions,
IConstraint[] constraints,
IBindingSet constants,
IRuleTaskFactory taskFactory,
IVariable[] requiredVars)
Fully specified ctor.
|
Modifier and Type | Field and Description |
---|---|
protected IVariable[][] |
TestRuleState.RuleState2.requiredVars |
protected IVariable[][] |
RuleState.requiredVars
Each step in the join has a set of variables that are required, either
by that tail or by something downstream, be it another tail or the
projection (select or construct) or the aggregation phase.
|
Modifier and Type | Method and Description |
---|---|
static IVariable[][] |
RuleState.computeRequiredVarsForEachTail(IRule rule,
int[] order)
Return an array indicated what variables are required for each tail
index.
|
IVariable[][] |
RuleState.getRequiredVars() |
IVariable[][] |
IRuleState.getRequiredVars()
A list of variables required for each tail, by tailIndex.
|
Modifier and Type | Field and Description |
---|---|
protected IVariable<?>[][] |
JoinTask.requiredVars
A list of variables required for each tail, by tailIndex.
|
Constructor and Description |
---|
DistributedJoinTask(IRule rule,
IJoinNexus joinNexus,
int[] order,
int orderIndex,
int partitionId,
AbstractScaleOutFederation<?> fed,
IJoinMaster master,
UUID masterUUID,
IAsynchronousIterator<IBindingSet[]> src,
IKeyOrder[] keyOrders,
DataService dataService,
IVariable[][] requiredVars) |
JoinTask(IRule rule,
IJoinNexus joinNexus,
int[] order,
int orderIndex,
int partitionId,
IJoinMaster masterProxy,
UUID masterUUID,
IVariable[][] requiredVars)
Instances of this class MUST be created in the appropriate execution
context of the target
DataService so that the federation and
the joinNexus references are both correct and so that it has access
to the local index object for the specified index partition. |
JoinTaskFactoryTask(String scaleOutIndexName,
IRule rule,
IJoinNexusFactory joinNexusFactory,
int[] order,
int orderIndex,
int partitionId,
IJoinMaster masterProxy,
UUID masterUUID,
IAsynchronousIterator<IBindingSet[]> sourceItrProxy,
IKeyOrder[] keyOrders,
IVariable[][] requiredVars) |
LocalJoinTask(IRule rule,
IJoinNexus joinNexus,
int[] order,
int orderIndex,
IJoinMaster masterProxy,
UUID masterUUID,
IAsynchronousIterator<IBindingSet[]> source,
IBuffer<ISolution[]> solutionBuffer,
IVariable[][] requiredVars) |
Modifier and Type | Method and Description |
---|---|
Set<IVariable<?>> |
FulltextSearchServiceFactory.getRequiredBound(ServiceNode serviceNode) |
Modifier and Type | Method and Description |
---|---|
IVariable<?> |
IGeoSpatialQuery.getCoordSystemVar() |
IVariable<?> |
IGeoSpatialQuery.getCustomFieldsVar() |
IVariable<?> |
IGeoSpatialQuery.getDistanceVar() |
IVariable<?> |
IGeoSpatialQuery.getLatVar() |
IVariable<?> |
IGeoSpatialQuery.getLiteralVar() |
IVariable<?> |
IGeoSpatialQuery.getLocationAndTimeVar() |
IVariable<?> |
IGeoSpatialQuery.getLocationVar() |
IVariable<?> |
IGeoSpatialQuery.getLonVar() |
IVariable<?> |
IGeoSpatialQuery.getTimeVar() |
Modifier and Type | Method and Description |
---|---|
IVariable<?> |
GeoSpatialQuery.getCoordSystemVar() |
IVariable<?> |
GeoSpatialQuery.getCustomFieldsVar() |
IVariable<?> |
GeoSpatialQuery.getDistanceVar() |
IVariable<?> |
GeoSpatialQuery.getLatVar() |
IVariable<?> |
GeoSpatialQuery.getLiteralVar() |
IVariable<?> |
GeoSpatialQuery.getLocationAndTimeVar() |
IVariable<?> |
GeoSpatialQuery.getLocationVar() |
IVariable<?> |
GeoSpatialQuery.getLonVar() |
IVariable<?> |
GeoSpatialQuery.getTimeVar() |
Constructor and Description |
---|
GeoSpatialQuery(GeoSpatialConfig geoSpatialConfig,
GeoSpatial.GeoFunction searchFunction,
org.openrdf.model.URI searchDatatype,
IConstant<?> subject,
TermNode predicate,
TermNode context,
GeoSpatialUtility.PointLatLon spatialCircleCenter,
Double spatialCircleRadius,
GeoSpatialUtility.PointLatLon spatialRectangleSouthWest,
GeoSpatialUtility.PointLatLon spatialRectangleNorthEast,
ICoordinate.UNITS spatialUnit,
Long timeStart,
Long timeEnd,
Long coordSystem,
Map<String,IGeoSpatialQuery.LowerAndUpperValue> customFieldsConstraints,
IVariable<?> locationVar,
IVariable<?> timeVar,
IVariable<?> locationAndTimeVar,
IVariable<?> latVar,
IVariable<?> lonVar,
IVariable<?> coordSystemVar,
IVariable<?> customFieldsVar,
IVariable<?> literalVar,
IVariable<?> distanceVar,
IBindingSet incomingBindings)
Constructor
|
GeoSpatialQuery(GeoSpatialConfig geoSpatialConfig,
GeoSpatial.GeoFunction searchFunction,
org.openrdf.model.URI searchDatatype,
IConstant<?> subject,
TermNode predicate,
TermNode context,
GeoSpatialUtility.PointLatLon spatialCircleCenter,
Double spatialCircleRadius,
GeoSpatialUtility.PointLatLon spatialRectangleSouthWest,
GeoSpatialUtility.PointLatLon spatialRectangleNorthEast,
ICoordinate.UNITS spatialUnit,
Long timeStart,
Long timeEnd,
Long coordSystem,
Map<String,IGeoSpatialQuery.LowerAndUpperValue> customFieldsConstraints,
IVariable<?> locationVar,
IVariable<?> timeVar,
IVariable<?> locationAndTimeVar,
IVariable<?> latVar,
IVariable<?> lonVar,
IVariable<?> coordSystemVar,
IVariable<?> customFieldsVar,
IVariable<?> literalVar,
IVariable<?> distanceVar,
IBindingSet incomingBindings)
Constructor
|
GeoSpatialQuery(GeoSpatialConfig geoSpatialConfig,
GeoSpatial.GeoFunction searchFunction,
org.openrdf.model.URI searchDatatype,
IConstant<?> subject,
TermNode predicate,
TermNode context,
GeoSpatialUtility.PointLatLon spatialCircleCenter,
Double spatialCircleRadius,
GeoSpatialUtility.PointLatLon spatialRectangleSouthWest,
GeoSpatialUtility.PointLatLon spatialRectangleNorthEast,
ICoordinate.UNITS spatialUnit,
Long timeStart,
Long timeEnd,
Long coordSystem,
Map<String,IGeoSpatialQuery.LowerAndUpperValue> customFieldsConstraints,
IVariable<?> locationVar,
IVariable<?> timeVar,
IVariable<?> locationAndTimeVar,
IVariable<?> latVar,
IVariable<?> lonVar,
IVariable<?> coordSystemVar,
IVariable<?> customFieldsVar,
IVariable<?> literalVar,
IVariable<?> distanceVar,
IBindingSet incomingBindings)
Constructor
|
GeoSpatialQuery(GeoSpatialConfig geoSpatialConfig,
GeoSpatial.GeoFunction searchFunction,
org.openrdf.model.URI searchDatatype,
IConstant<?> subject,
TermNode predicate,
TermNode context,
GeoSpatialUtility.PointLatLon spatialCircleCenter,
Double spatialCircleRadius,
GeoSpatialUtility.PointLatLon spatialRectangleSouthWest,
GeoSpatialUtility.PointLatLon spatialRectangleNorthEast,
ICoordinate.UNITS spatialUnit,
Long timeStart,
Long timeEnd,
Long coordSystem,
Map<String,IGeoSpatialQuery.LowerAndUpperValue> customFieldsConstraints,
IVariable<?> locationVar,
IVariable<?> timeVar,
IVariable<?> locationAndTimeVar,
IVariable<?> latVar,
IVariable<?> lonVar,
IVariable<?> coordSystemVar,
IVariable<?> customFieldsVar,
IVariable<?> literalVar,
IVariable<?> distanceVar,
IBindingSet incomingBindings)
Constructor
|
GeoSpatialQuery(GeoSpatialConfig geoSpatialConfig,
GeoSpatial.GeoFunction searchFunction,
org.openrdf.model.URI searchDatatype,
IConstant<?> subject,
TermNode predicate,
TermNode context,
GeoSpatialUtility.PointLatLon spatialCircleCenter,
Double spatialCircleRadius,
GeoSpatialUtility.PointLatLon spatialRectangleSouthWest,
GeoSpatialUtility.PointLatLon spatialRectangleNorthEast,
ICoordinate.UNITS spatialUnit,
Long timeStart,
Long timeEnd,
Long coordSystem,
Map<String,IGeoSpatialQuery.LowerAndUpperValue> customFieldsConstraints,
IVariable<?> locationVar,
IVariable<?> timeVar,
IVariable<?> locationAndTimeVar,
IVariable<?> latVar,
IVariable<?> lonVar,
IVariable<?> coordSystemVar,
IVariable<?> customFieldsVar,
IVariable<?> literalVar,
IVariable<?> distanceVar,
IBindingSet incomingBindings)
Constructor
|
GeoSpatialQuery(GeoSpatialConfig geoSpatialConfig,
GeoSpatial.GeoFunction searchFunction,
org.openrdf.model.URI searchDatatype,
IConstant<?> subject,
TermNode predicate,
TermNode context,
GeoSpatialUtility.PointLatLon spatialCircleCenter,
Double spatialCircleRadius,
GeoSpatialUtility.PointLatLon spatialRectangleSouthWest,
GeoSpatialUtility.PointLatLon spatialRectangleNorthEast,
ICoordinate.UNITS spatialUnit,
Long timeStart,
Long timeEnd,
Long coordSystem,
Map<String,IGeoSpatialQuery.LowerAndUpperValue> customFieldsConstraints,
IVariable<?> locationVar,
IVariable<?> timeVar,
IVariable<?> locationAndTimeVar,
IVariable<?> latVar,
IVariable<?> lonVar,
IVariable<?> coordSystemVar,
IVariable<?> customFieldsVar,
IVariable<?> literalVar,
IVariable<?> distanceVar,
IBindingSet incomingBindings)
Constructor
|
GeoSpatialQuery(GeoSpatialConfig geoSpatialConfig,
GeoSpatial.GeoFunction searchFunction,
org.openrdf.model.URI searchDatatype,
IConstant<?> subject,
TermNode predicate,
TermNode context,
GeoSpatialUtility.PointLatLon spatialCircleCenter,
Double spatialCircleRadius,
GeoSpatialUtility.PointLatLon spatialRectangleSouthWest,
GeoSpatialUtility.PointLatLon spatialRectangleNorthEast,
ICoordinate.UNITS spatialUnit,
Long timeStart,
Long timeEnd,
Long coordSystem,
Map<String,IGeoSpatialQuery.LowerAndUpperValue> customFieldsConstraints,
IVariable<?> locationVar,
IVariable<?> timeVar,
IVariable<?> locationAndTimeVar,
IVariable<?> latVar,
IVariable<?> lonVar,
IVariable<?> coordSystemVar,
IVariable<?> customFieldsVar,
IVariable<?> literalVar,
IVariable<?> distanceVar,
IBindingSet incomingBindings)
Constructor
|
GeoSpatialQuery(GeoSpatialConfig geoSpatialConfig,
GeoSpatial.GeoFunction searchFunction,
org.openrdf.model.URI searchDatatype,
IConstant<?> subject,
TermNode predicate,
TermNode context,
GeoSpatialUtility.PointLatLon spatialCircleCenter,
Double spatialCircleRadius,
GeoSpatialUtility.PointLatLon spatialRectangleSouthWest,
GeoSpatialUtility.PointLatLon spatialRectangleNorthEast,
ICoordinate.UNITS spatialUnit,
Long timeStart,
Long timeEnd,
Long coordSystem,
Map<String,IGeoSpatialQuery.LowerAndUpperValue> customFieldsConstraints,
IVariable<?> locationVar,
IVariable<?> timeVar,
IVariable<?> locationAndTimeVar,
IVariable<?> latVar,
IVariable<?> lonVar,
IVariable<?> coordSystemVar,
IVariable<?> customFieldsVar,
IVariable<?> literalVar,
IVariable<?> distanceVar,
IBindingSet incomingBindings)
Constructor
|
GeoSpatialQuery(GeoSpatialConfig geoSpatialConfig,
GeoSpatial.GeoFunction searchFunction,
org.openrdf.model.URI searchDatatype,
IConstant<?> subject,
TermNode predicate,
TermNode context,
GeoSpatialUtility.PointLatLon spatialCircleCenter,
Double spatialCircleRadius,
GeoSpatialUtility.PointLatLon spatialRectangleSouthWest,
GeoSpatialUtility.PointLatLon spatialRectangleNorthEast,
ICoordinate.UNITS spatialUnit,
Long timeStart,
Long timeEnd,
Long coordSystem,
Map<String,IGeoSpatialQuery.LowerAndUpperValue> customFieldsConstraints,
IVariable<?> locationVar,
IVariable<?> timeVar,
IVariable<?> locationAndTimeVar,
IVariable<?> latVar,
IVariable<?> lonVar,
IVariable<?> coordSystemVar,
IVariable<?> customFieldsVar,
IVariable<?> literalVar,
IVariable<?> distanceVar,
IBindingSet incomingBindings)
Constructor
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.