Modifier and Type | Method and Description |
---|---|
static ResultSet |
ResultSetFactory.create(QueryIterator queryIterator,
List<String> vars)
Build a result set from one of ARQ's lower level query iterator.
|
Modifier and Type | Method and Description |
---|---|
static QueryIterator |
Algebra.exec(Op op,
Dataset ds) |
static QueryIterator |
Algebra.exec(Op op,
DatasetGraph ds) |
static QueryIterator |
Algebra.exec(Op op,
Graph graph) |
static QueryIterator |
Algebra.exec(Op op,
Model model) |
static QueryIterator |
Algebra.execRef(Op op,
Dataset ds) |
static QueryIterator |
Algebra.execRef(Op op,
DatasetGraph dsg) |
static QueryIterator |
Algebra.execRef(Op op,
Graph graph) |
static QueryIterator |
Algebra.execRef(Op op,
Model model) |
QueryIterator |
Table.iterator(ExecutionContext execCxt) |
QueryIterator |
Table.matchRightLeft(Binding bindingLeft,
boolean includeOnNoMatch,
ExprList condition,
ExecutionContext execCxt) |
Modifier and Type | Method and Description |
---|---|
static Table |
TableFactory.create(QueryIterator queryIterator) |
Modifier and Type | Method and Description |
---|---|
abstract QueryIterator |
OpExt.eval(QueryIterator input,
ExecutionContext execCxt)
Evaluate the op, given a stream of bindings as input
Throw UnsupportedOperationException if this OpExt is not executeable.
|
Modifier and Type | Method and Description |
---|---|
abstract QueryIterator |
OpExt.eval(QueryIterator input,
ExecutionContext execCxt)
Evaluate the op, given a stream of bindings as input
Throw UnsupportedOperationException if this OpExt is not executeable.
|
Modifier and Type | Method and Description |
---|---|
QueryIterator |
Table1.iterator(ExecutionContext execCxt) |
QueryIterator |
TableUnit.iterator(ExecutionContext execCxt) |
QueryIterator |
TableEmpty.iterator(ExecutionContext execCxt) |
QueryIterator |
TableN.iterator(ExecutionContext execCxt) |
QueryIterator |
Table1.matchRightLeft(Binding bindingLeft,
boolean includeOnNoMatch,
ExprList conditions,
ExecutionContext execContext) |
QueryIterator |
TableUnit.matchRightLeft(Binding bindingLeft,
boolean includeOnNoMatch,
ExprList conditions,
ExecutionContext execCxt) |
QueryIterator |
TableEmpty.matchRightLeft(Binding bindingLeft,
boolean includeOnNoMatch,
ExprList conditions,
ExecutionContext execContext) |
QueryIterator |
TableN.matchRightLeft(Binding bindingLeft,
boolean includeOnNoMatch,
ExprList conditions,
ExecutionContext execContext) |
Constructor and Description |
---|
TableN(QueryIterator qIter) |
Modifier and Type | Method and Description |
---|---|
QueryIterator |
OpEval.evaluate(Op op,
DatasetGraph dsg,
Binding binding,
Context context) |
QueryIterator |
QueryEngineBase.evaluate(Op op,
DatasetGraph dsg,
Binding binding,
Context context) |
QueryIterator |
PlanBase.iterator() |
QueryIterator |
Plan.iterator() |
Modifier and Type | Method and Description |
---|---|
Iterator<QueryIterator> |
ExecutionContext.listAllIterators() |
Iterator<QueryIterator> |
ExecutionContext.listOpenIterators() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionContext.closedIterator(QueryIterator qIter) |
void |
ExecutionContext.openIterator(QueryIterator qIter) |
Constructor and Description |
---|
PlanOp(Op op,
Closeable closeable,
QueryIterator qIter) |
PlanOp(String label,
Closeable closeable,
Op op,
QueryIterator qIter) |
Modifier and Type | Method and Description |
---|---|
static QueryIterator |
Service.exec(OpService op,
Context context) |
Modifier and Type | Method and Description |
---|---|
static IndexTable |
IndexFactory.createIndex(Set<Var> commonVars,
QueryIterator data) |
Constructor and Description |
---|
HashIndexTable(Set<Var> commonVars,
QueryIterator data) |
LinearIndex(Set<Var> commonVars,
QueryIterator data) |
LinearIndex(Set<Var> commonVars,
QueryIterator data,
Set<com.hp.hpl.jena.sparql.engine.index.HashIndexTable.Key> loadedData,
Map<Var,Integer> mappings) |
Modifier and Type | Class and Description |
---|---|
class |
QueryIter
This class provides the general machinary for iterators.
|
class |
QueryIter1
This class supports a QueryIter that takes one QueryIterator as input.
|
class |
QueryIter2
This class marks a QueryIter that takes two QueryIterators as input.
|
class |
QueryIter2LoopOnLeft
Binary operation done by looping on the left, and materializing the right - this is not streamed on the right
See also QueryIterRepeatApply
|
class |
QueryIterAssign
Extend each solution by a (var, expression)
|
class |
QueryIterAssignVarValue
Extend each solution by a (var, node)
When used with mustBeNewVar=false, this is a join.
|
class |
QueryIteratorBase
This class provides the general machinary for iterators.
|
class |
QueryIteratorCaching
A caching QueryIterator.
|
class |
QueryIteratorCheck
Query iterator that checks everything was closed correctly
|
class |
QueryIteratorCloseable |
class |
QueryIteratorLogging
Intercept and print iterator operations
|
class |
QueryIteratorResultSet |
class |
QueryIteratorTiming |
class |
QueryIteratorWrapper
Wrap a QueryIterator so it can have some/all of it's methods intercepted.
|
class |
QueryIterBlockTriples |
class |
QueryIterCommonParent
Yield new bindings, with a fixed parent, with values from an iterator.
|
class |
QueryIterConcat
A query iterator that joins two or more iterators into a single iterator.
|
class |
QueryIterConvert
Iterator over another QueryIterator, applying a converter function
to each object that is returned by .next()
|
class |
QueryIterDefaulting
An iterator that returns at least one element from another iterator
or a default value (once) if the wrapped iterator returns nothing.
|
class |
QueryIterDiff
Diff by materializing the RHS - this is not streamed on the right
|
class |
QueryIterDistinct
A QueryIterator that suppresses items already seen.
|
class |
QueryIterDistinctMem
Memory limited QueryIterDistinct
|
class |
QueryIterDistinctReduced
Implementation skeleton for DISTINCT and REDUCED.
|
class |
QueryIterDistinguishedVars
Filter bindings for distinguished variables only
Currently unused.
|
class |
QueryIterExtendByVar
Yield new bindings, with a fixed parent, with values from an iterator.
|
class |
QueryIterFilterExpr
Filter a stream of bindings by a constraint.
|
class |
QueryIterGroup |
class |
QueryIterMinus
Minus by materializing the RHS - this is not streamed on the right
|
class |
QueryIterNullIterator
Closeable empty query iterator
|
class |
QueryIterPath |
class |
QueryIterPeek |
class |
QueryIterPlainWrapper
Turn an normal java.util.Iterator (of Bindings) into a QueryIterator
|
class |
QueryIterProcedure
QueryIterator for a procedure.
|
class |
QueryIterProcessBinding
An iterator that applying a condition.
|
class |
QueryIterProject |
class |
QueryIterProject2 |
class |
QueryIterReduced |
class |
QueryIterRepeatApply
Repeatedly execute the subclass operation for each Binding in the input iterator.
|
class |
QueryIterRoot |
class |
QueryIterSingleton
A singleton iterator
|
class |
QueryIterSlice
Iterator until a limit is reached.
|
class |
QueryIterSort
Sort a query iterator.
|
class |
QueryIterSub
This class supports a QueryIter that uses a single sub iterator.
|
class |
QueryIterTopN |
class |
QueryIterTracked
Track a QueryIterator
|
class |
QueryIterTriplePattern |
class |
QueryIterYieldN
A query iterator that yields the same thing N times.
|
Modifier and Type | Method and Description |
---|---|
static QueryIterator |
QueryIterBlockTriples.create(QueryIterator input,
BasicPattern pattern,
ExecutionContext execContext) |
static QueryIterator |
QueryIter.materialize(QueryIterator qIter) |
static QueryIterator |
QueryIteratorCaching.reset(QueryIterator qIter) |
Modifier and Type | Method and Description |
---|---|
void |
QueryIterConcat.add(QueryIterator qIter) |
static QueryIteratorCheck |
QueryIteratorCheck.check(QueryIterator qIter,
ExecutionContext execCxt) |
static QueryIterator |
QueryIterBlockTriples.create(QueryIterator input,
BasicPattern pattern,
ExecutionContext execContext) |
static QueryIterPeek |
QueryIterPeek.create(QueryIterator iterator,
ExecutionContext cxt) |
static QueryIter |
QueryIter.makeTracked(QueryIterator qIter,
ExecutionContext execCxt) |
static QueryIterator |
QueryIter.materialize(QueryIterator qIter) |
static QueryIter |
QueryIter.materialize(QueryIterator qIter,
ExecutionContext execCxt) |
static QueryIterator |
QueryIteratorCaching.reset(QueryIterator qIter) |
static QueryIteratorTiming |
QueryIteratorTiming.time(QueryIterator iter) |
Modifier and Type | Method and Description |
---|---|
QueryIterator |
StageGeneratorGeneric.execute(BasicPattern pattern,
QueryIterator input,
ExecutionContext execCxt) |
QueryIterator |
StageGenerator.execute(BasicPattern pattern,
QueryIterator input,
ExecutionContext execCxt) |
static QueryIterator |
StageBuilder.execute(BasicPattern pattern,
QueryIterator input,
ExecutionContext execCxt) |
static QueryIterator |
QC.execute(Op op,
QueryIterator qIter,
ExecutionContext execCxt) |
static QueryIterator |
QC.executeDirect(BasicPattern pattern,
QueryIterator input,
ExecutionContext execCxt)
Execute a BGP directly - no optimization.
|
static QueryIterator |
StageGeneratorGeneric.executeInline(BasicPattern pattern,
QueryIterator input,
ExecutionContext execCxt)
Use the inline BGP matcher
|
QueryIterator |
OpExecutor.executeOp(Op op,
QueryIterator input) |
Modifier and Type | Class and Description |
---|---|
class |
QueryIterGraph |
class |
QueryIterJoin
Join by materializing the RHS - this is not streamed
|
class |
QueryIterJoinBase
Join or LeftJoin by calculating both sides, then doing the join
It usually better to use substitute algorithm (not this
QueryIterator in other words) as that is effectively indexing
from one side into the other.
|
class |
QueryIterLeftJoin
Left join by materializing the RHS
|
class |
QueryIterOptionalIndex |
class |
QueryIterService |
class |
QueryIterUnion
Execute each sub stage against the input.
|
Constructor and Description |
---|
QueryIterGraph(QueryIterator input,
OpGraph opGraph,
ExecutionContext context) |
QueryIterJoin(QueryIterator left,
QueryIterator right,
ExecutionContext qCxt) |
QueryIterJoinBase(QueryIterator left,
QueryIterator right,
ExprList exprs,
ExecutionContext execCxt) |
QueryIterJoinBase(QueryIterator left,
Table right,
ExprList exprs,
ExecutionContext execCxt) |
QueryIterLeftJoin(QueryIterator left,
QueryIterator right,
ExprList exprs,
ExecutionContext qCxt) |
QueryIterOptionalIndex(QueryIterator input,
Op op,
ExecutionContext context) |
QueryIterService(QueryIterator input,
OpService opService,
ExecutionContext context) |
QueryIterUnion(QueryIterator input,
List<Op> subOps,
ExecutionContext context) |
Modifier and Type | Method and Description |
---|---|
QueryIterator |
QueryEngineRef.eval(Op op,
DatasetGraph dsg,
Binding binding,
Context context) |
Modifier and Type | Method and Description |
---|---|
QueryIterator |
PathPropertyFunction.execEvaluated(Binding binding,
Node subject,
Node predicate,
Node object,
ExecutionContext execCxt) |
static QueryIterator |
PathLib.execTriplePath(Binding binding,
Node s,
Path path,
Node o,
ExecutionContext execCxt) |
static QueryIterator |
PathLib.execTriplePath(Binding binding,
TriplePath triplePath,
ExecutionContext execCxt) |
Modifier and Type | Method and Description |
---|---|
abstract QueryIterator |
PropertyFunctionBase.exec(Binding binding,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt) |
QueryIterator |
PropertyFunctionEval.exec(Binding binding,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt) |
QueryIterator |
PropertyFunction.exec(QueryIterator input,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt)
Create an iterator of bindings for the given inputs
|
QueryIterator |
PropertyFunctionBase.exec(QueryIterator input,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt) |
QueryIterator |
PFuncAssignToSubject.execEvaluated(Binding binding,
Node subject,
Node predicate,
Node object,
ExecutionContext execCxt) |
abstract QueryIterator |
PFuncSimple.execEvaluated(Binding binding,
Node subject,
Node predicate,
Node object,
ExecutionContext execCxt) |
abstract QueryIterator |
PFuncSimpleAndList.execEvaluated(Binding binding,
Node subject,
Node predicate,
PropFuncArg object,
ExecutionContext execCxt) |
QueryIterator |
PFuncSimpleAndList.execEvaluated(Binding binding,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt) |
QueryIterator |
PFuncSimple.execEvaluated(Binding binding,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt) |
abstract QueryIterator |
PropertyFunctionEval.execEvaluated(Binding binding,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt) |
QueryIterator |
ProcedurePF.proc(QueryIterator input,
ExecutionContext execCxt) |
Modifier and Type | Method and Description |
---|---|
QueryIterator |
PropertyFunction.exec(QueryIterator input,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt)
Create an iterator of bindings for the given inputs
|
QueryIterator |
PropertyFunctionBase.exec(QueryIterator input,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt) |
QueryIterator |
ProcedurePF.proc(QueryIterator input,
ExecutionContext execCxt) |
Modifier and Type | Method and Description |
---|---|
QueryIterator |
assign.execEvaluated(Binding binding,
Node subject,
Node predicate,
Node object,
ExecutionContext execCxt) |
QueryIterator |
container.execEvaluated(Binding binding,
Node containerNode,
Node predicate,
Node member,
ExecutionContext execCxt) |
QueryIterator |
str.execEvaluated(Binding binding,
Node subject,
Node predicate,
Node object,
ExecutionContext execCxt) |
QueryIterator |
blankNode.execEvaluated(Binding binding,
Node subject,
Node predicate,
Node object,
ExecutionContext execCxt) |
QueryIterator |
concat.execEvaluated(Binding binding,
Node subject,
Node predicate,
PropFuncArg object,
ExecutionContext execCxt) |
QueryIterator |
versionARQ.execEvaluated(Binding binding,
PropFuncArg subject,
Node predicate,
PropFuncArg object,
ExecutionContext execCxt) |
QueryIterator |
version.execEvaluated(Binding binding,
PropFuncArg subject,
Node predicate,
PropFuncArg object,
ExecutionContext execCxt) |
QueryIterator |
splitIRI.execEvaluated(Binding binding,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt) |
QueryIterator |
ListBase.execEvaluated(Binding binding,
PropFuncArg argSubject,
Node predicate,
PropFuncArg argObject,
ExecutionContext execCxt)
If the subject is a list (well, at least not an unbound variable), dispatch to execOneList
else dispatch to one of object a var, a list or a node.
|
QueryIterator |
listLength.execOneList(Binding binding,
Node listNode,
Node predicate,
Node length,
ExecutionContext execCxt) |
Modifier and Type | Method and Description |
---|---|
static QueryIterator |
ProcEval.eval(QueryIterator queryIterator,
Procedure proc,
ExecutionContext execCxt)
Evaluate a procedure
|
QueryIterator |
ProcedureEval.exec(Binding binding,
Node name,
ExprList args,
ExecutionContext execCxt) |
abstract QueryIterator |
ProcedureBase.exec(Binding binding,
Node name,
ExprList args,
ExecutionContext execCxt) |
abstract QueryIterator |
ProcedureEval.execEval(Binding binding,
ExprList args,
ExecutionContext execCxt) |
QueryIterator |
Procedure.proc(QueryIterator input,
ExecutionContext execCxt)
Call the procedure, with an input iterator of bindings.
|
QueryIterator |
ProcedureBase.proc(QueryIterator input,
ExecutionContext execCxt) |
Modifier and Type | Method and Description |
---|---|
static QueryIterator |
ProcEval.eval(QueryIterator queryIterator,
Procedure proc,
ExecutionContext execCxt)
Evaluate a procedure
|
QueryIterator |
Procedure.proc(QueryIterator input,
ExecutionContext execCxt)
Call the procedure, with an input iterator of bindings.
|
QueryIterator |
ProcedureBase.proc(QueryIterator input,
ExecutionContext execCxt) |
Modifier and Type | Method and Description |
---|---|
QueryIterator |
debug.execEval(Binding binding,
ExprList args,
ExecutionContext execCxt) |
Modifier and Type | Class and Description |
---|---|
class |
CSVInputIterator
Class used to do streaming parsing of actual result rows from the CSV
|
class |
TSVInputIterator
Class used to do streaming parsing of actual result rows from the TSV
|
Modifier and Type | Method and Description |
---|---|
static QueryIterator |
IterLib.noResults(ExecutionContext execCxt) |
static QueryIterator |
IterLib.oneResult(Binding binding,
Var var,
Node value,
ExecutionContext execCxt) |
static QueryIterator |
IterLib.result(Binding binding,
ExecutionContext execCxt) |
Licenced under the Apache License, Version 2.0