Modifier and Type | Class and Description |
---|---|
class |
LockingIteration<E,X extends Exception>
An Iteration that holds on to a lock until the Iteration is closed.
|
Modifier and Type | Class and Description |
---|---|
class |
CloseableIterationBase<E,X extends Exception>
Base class for
CloseableIteration s offering common functionality. |
class |
CloseableIteratorIteration<E,X extends Exception>
An Iteration that can convert an
Iterator to a
CloseableIteration . |
class |
ConvertingIteration<S,T,X extends Exception>
A CloseableIteration that converts an iteration over objects of type
S (the source type) to an iteration over objects of type
T (the target type).
|
class |
DelayedIteration<E,X extends Exception>
An iteration that delays the creation of the underlying iteration until it is
being accessed.
|
class |
DistinctIteration<E,X extends Exception>
An Iteration that filters any duplicate elements from an underlying iterator.
|
class |
EmptyIteration<E,X extends Exception>
An iterator that does not contain any elements.
|
class |
ExceptionConvertingIteration<E,X extends Exception>
A CloseableIteration that converts an arbitrary iteration to an iteration
with exceptions of type X.
|
class |
FilterIteration<E,X extends Exception>
A CloseableIteration that wraps another Iteration, applying a filter on the
objects that are returned.
|
class |
IntersectIteration<E,X extends Exception>
An Iteration that returns the intersection of the results of two Iterations.
|
class |
IterationWrapper<E,X extends Exception>
Abstract superclass for Iterations that wrap other Iterations.
|
class |
LimitIteration<E,X extends Exception>
An Iteration that limits the amount of elements that it returns from an
underlying Iteration to a fixed amount.
|
class |
LookAheadIteration<E,X extends Exception>
An Iteration that looks one element ahead, if necessary, to handle calls to
LookAheadIteration.hasNext() . |
class |
MinusIteration<E,X extends Exception>
An Iteration that returns the results of an Iteration (the left argument)
minus the results of another Iteration (the right argument).
|
class |
OffsetIteration<E,X extends Exception>
An Iteration that skips the first offset elements from an
underlying Iteration.
|
class |
ReducedIteration<E,X extends Exception>
Removes consecutive duplicates from the object stream.
|
class |
SingletonIteration<E,X extends Exception>
An Iteration that contains exactly one element.
|
class |
TimeLimitIteration<E,X extends Exception> |
class |
UnionIteration<E,X extends Exception>
An Iteration that returns the bag union of the results of a number of
Iterations.
|
Modifier and Type | Class and Description |
---|---|
class |
BackgroundGraphResult
Provides concurrent access to statements as they are being parsed.
|
class |
BackgroundTupleResult
Provides concurrent access to tuple results as they are being parsed.
|
class |
QueueCursor<E>
Makes working with a queue easier by adding the methods
QueueCursor.done() and
QueueCursor.toss(Exception) and automatically converting the exception into a
QueryEvaluationException with an appropriate stack trace. |
Modifier and Type | Interface and Description |
---|---|
interface |
GraphQueryResult
A representation of a query result as a sequence of
Statement
objects. |
interface |
QueryResult<T>
Super type of all query result types (TupleQueryResult, GraphQueryResult,
etc.).
|
interface |
TupleQueryResult
A representation of a variable-binding query result as a sequence of
BindingSet objects. |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
EvaluationStrategy.evaluate(Service expr,
String serviceUri,
CloseableIteration<BindingSet,QueryEvaluationException> bindings)
Evaluates the tuple expression against the supplied triple source with the
specified set of variable bindings as input.
|
CloseableIteration<BindingSet,QueryEvaluationException> |
EvaluationStrategy.evaluate(TupleExpr expr,
BindingSet bindings)
Evaluates the tuple expression against the supplied triple source with the
specified set of variable bindings as input.
|
CloseableIteration<? extends Statement,QueryEvaluationException> |
TripleSource.getStatements(Resource subj,
URI pred,
Value obj,
Resource... contexts)
Gets all statements that have a specific subject, predicate and/or object.
|
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
EvaluationStrategy.evaluate(Service expr,
String serviceUri,
CloseableIteration<BindingSet,QueryEvaluationException> bindings)
Evaluates the tuple expression against the supplied triple source with the
specified set of variable bindings as input.
|
Modifier and Type | Class and Description |
---|---|
class |
JoinExecutorBase<T>
Base class for any join parallel join executor.
|
class |
ServiceCrossProductIteration
Iteration which forms the cross product of a list of materialized input bindings
with each result obtained from the inner iteration.
|
class |
ServiceFallbackIteration
Fallback join handler, if the block join can not be performed, e.g.
|
class |
ServiceJoinConversionIteration
Inserts original bindings into the result, uses ?__rowIdx to resolve original
bindings.
|
class |
ServiceJoinIterator
Iterator for efficient SERVICE evaluation (vectored).
|
Modifier and Type | Field and Description |
---|---|
protected CloseableIteration<T,QueryEvaluationException> |
JoinExecutorBase.leftIter |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ServiceCrossProductIteration.resultIteration |
protected CloseableIteration<T,QueryEvaluationException> |
JoinExecutorBase.rightIter |
Modifier and Type | Field and Description |
---|---|
protected QueueCursor<CloseableIteration<T,QueryEvaluationException>> |
JoinExecutorBase.rightQueue |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
FederatedService.evaluate(Service service,
CloseableIteration<BindingSet,QueryEvaluationException> bindings,
String baseUri)
Evaluate the provided SPARQL query at this federated service,
possibilities for vectored evaluation.
|
CloseableIteration<BindingSet,QueryEvaluationException> |
RepositoryFederatedService.evaluate(Service service,
CloseableIteration<BindingSet,QueryEvaluationException> bindings,
String baseUri) |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
RepositoryFederatedService.evaluateInternal(Service service,
CloseableIteration<BindingSet,QueryEvaluationException> bindings,
String baseUri)
Evaluate the SPARQL query that can be constructed from the SERVICE node at
the initialized
Repository of this FederatedService . |
CloseableIteration<BindingSet,QueryEvaluationException> |
FederatedService.select(Service service,
Set<String> projectionVars,
BindingSet bindings,
String baseUri)
Evaluate the provided SPARQL query at this federated service.
|
CloseableIteration<BindingSet,QueryEvaluationException> |
RepositoryFederatedService.select(Service service,
Set<String> projectionVars,
BindingSet bindings,
String baseUri)
Evaluate the provided sparqlQueryString at the initialized
Repository of this FederatedService . |
Constructor and Description |
---|
JoinExecutorBase(CloseableIteration<T,QueryEvaluationException> leftIter,
TupleExpr rightArg,
BindingSet bindings) |
ServiceCrossProductIteration(CloseableIteration<BindingSet,QueryEvaluationException> resultIteration,
List<BindingSet> inputBindings) |
ServiceJoinConversionIteration(CloseableIteration<BindingSet,QueryEvaluationException> iter,
List<BindingSet> bindings) |
ServiceJoinIterator(CloseableIteration<BindingSet,QueryEvaluationException> leftIter,
Service service,
BindingSet bindings,
EvaluationStrategy strategy)
Construct a service join iteration to use vectored evaluation.
|
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
EvaluationStrategyImpl.evaluate(Service service,
String serviceUri,
CloseableIteration<BindingSet,QueryEvaluationException> bindings) |
Modifier and Type | Class and Description |
---|---|
class |
BadlyDesignedLeftJoinIterator |
class |
BottomUpJoinIterator
Deprecated.
replaced by HashJoinIteration
|
class |
CollectionIteration<E,X extends Exception>
An iteration to access a materialized
Collection of BindingSets. |
class |
CompatibleBindingSetFilter
Deprecated.
|
class |
DescribeIteration
Iteration that implements a simplified version of Symmetric Concise Bounded
Description (omitting reified statements).
|
class |
ExtensionIterator |
class |
FilterIterator |
class |
GroupIterator |
class |
HashJoinIteration
Generic hash join implementation suitable for use by Sail implementations.
|
class |
JoinIterator |
class |
LeftJoinIterator |
class |
MultiProjectionIterator |
class |
OrderIterator
Sorts the input and optionally applies limit and distinct.
|
class |
PathIteration |
class |
ProjectionIterator |
class |
SilentIteration
Wrap an inner iteration and suppress exceptions silently
|
class |
SPARQLMinusIteration<X extends Exception>
An Iteration that returns the results of an Iteration (the left argument)
MINUS any results that are compatible with results of another Iteration (the
right argument) or that have no shared variables.
|
class |
ZeroLengthPathIteration |
Modifier and Type | Field and Description |
---|---|
protected CloseableIteration<BindingSet,QueryEvaluationException> |
SilentIteration.iter |
Modifier and Type | Method and Description |
---|---|
protected Collection<BindingSet> |
HashJoinIteration.makeIterationCache(CloseableIteration<BindingSet,QueryEvaluationException> iter)
Utility methods to make it easier to inserted custom store dependent list
|
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
LimitedSizeEvaluationStrategy.evaluate(ArbitraryLengthPath alp,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
LimitedSizeEvaluationStrategy.evaluate(Difference difference,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
LimitedSizeEvaluationStrategy.evaluate(Distinct distinct,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
LimitedSizeEvaluationStrategy.evaluate(Intersection intersection,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
LimitedSizeEvaluationStrategy.evaluate(Join join,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
LimitedSizeEvaluationStrategy.evaluate(Order node,
BindingSet bindings) |
Modifier and Type | Class and Description |
---|---|
class |
LimitedSizeBottomUpJoinIterator
Deprecated.
replaced by LimitedSizeHashJoinIteration
|
class |
LimitedSizeDistinctIteration |
class |
LimitedSizeHashJoinIteration |
class |
LimitedSizeIntersectIteration |
class |
LimitedSizeOrderIteration |
class |
LimitedSizePathIterator |
class |
LimitedSizeSPARQLMinusIteration |
class |
LimitedSizeZeroLengthPathIteration |
Constructor and Description |
---|
LimitedSizeOrderIteration(CloseableIteration<BindingSet,QueryEvaluationException> iter,
Comparator<BindingSet> comparator,
AtomicLong used,
long maxSize) |
LimitedSizeOrderIteration(CloseableIteration<BindingSet,QueryEvaluationException> iter,
Comparator<BindingSet> comparator,
long limit,
boolean distinct,
AtomicLong used,
long maxSize) |
Modifier and Type | Class and Description |
---|---|
class |
GraphQueryResultImpl
An utility implementation of the
GraphQueryResult interface. |
class |
MutableTupleQueryResult
An implementation of the
TupleQueryResult interface that stores the
complete query result in memory. |
class |
TupleQueryResultImpl
A generic implementation of the
TupleQueryResult interface. |
Constructor and Description |
---|
GraphQueryResultImpl(Map<String,String> namespaces,
CloseableIteration<? extends Statement,? extends QueryEvaluationException> statementIter) |
TupleQueryResultImpl(List<String> bindingNames,
CloseableIteration<? extends BindingSet,QueryEvaluationException> bindingSetIter)
Creates a query result object with the supplied binding names.
|
Modifier and Type | Class and Description |
---|---|
class |
RepositoryResult<T>
|
Constructor and Description |
---|
RepositoryResult(CloseableIteration<? extends T,RepositoryException> iter) |
Modifier and Type | Class and Description |
---|---|
protected class |
SailQuery.QueryInterruptIteration |
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
SailQuery.enforceMaxQueryTime(CloseableIteration<? extends BindingSet,QueryEvaluationException> bindingsIter) |
Modifier and Type | Method and Description |
---|---|
protected <E> RepositoryResult<E> |
SailRepositoryConnection.createRepositoryResult(CloseableIteration<? extends E,SailException> sailIter)
Wraps a CloseableIteration coming from a Sail in a RepositoryResult
object, applying the required conversions
|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
SailQuery.enforceMaxQueryTime(CloseableIteration<? extends BindingSet,QueryEvaluationException> bindingsIter) |
Modifier and Type | Class and Description |
---|---|
class |
InsertBindingSetCursor
Adds more bindings to each of the results.
|
Constructor and Description |
---|
InsertBindingSetCursor(CloseableIteration<BindingSet,QueryEvaluationException> delegate,
BindingSet bindings) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends BindingSet,QueryEvaluationException> |
SailConnection.evaluate(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred)
Evaluates the supplied TupleExpr on the data contained in this Sail
object, using the (optional) dataset and supplied bindings as input
parameters.
|
CloseableIteration<? extends Resource,SailException> |
SailConnection.getContextIDs()
Returns the set of all unique context identifiers that are used to store
statements.
|
CloseableIteration<? extends Namespace,SailException> |
SailConnection.getNamespaces()
Gets the namespaces relevant to the data contained in this Sail object.
|
CloseableIteration<? extends Statement,SailException> |
SailConnection.getStatements(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
Resource... contexts)
Gets all statements from the specified contexts that have a specific
subject, predicate and/or object.
|
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
OwnedTupleExpr.evaluate(Dataset dataset,
BindingSet bindings) |
Modifier and Type | Class and Description |
---|---|
class |
AlternativeCursor<E>
If the primary cursor is empty, use the alternative cursor.
|
class |
FilterCursor
Provides a convenient constructor for
FilterIterator using the
condition. |
class |
ParallelJoinCursor
Iterate the left side and evaluate the right side in separate thread, only
iterate the right side in the controlling thread.
|
class |
ParallelLeftJoinCursor
Transform the condition into a filter and the right side into an
AlternativeCursor , then evaluate as a ParallelJoinCursor . |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
FederationStrategy.evaluate(Join join,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
FederationStrategy.evaluate(LeftJoin leftJoin,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
FederationStrategy.evaluate(NaryJoin join,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
FederationStrategy.evaluate(TupleExpr expr,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
FederationStrategy.evaluate(Union union,
BindingSet bindings) |
CloseableIteration<? extends Statement,QueryEvaluationException> |
RepositoryTripleSource.getStatements(Resource subj,
URI pred,
Value obj,
Resource... contexts) |
Constructor and Description |
---|
AlternativeCursor(CloseableIteration<? extends E,QueryEvaluationException> primary,
CloseableIteration<? extends E,QueryEvaluationException> alternative) |
AlternativeCursor(CloseableIteration<? extends E,QueryEvaluationException> primary,
CloseableIteration<? extends E,QueryEvaluationException> alternative) |
FilterCursor(CloseableIteration<BindingSet,QueryEvaluationException> result,
ValueExpr condition,
Set<String> scopeBindingNames,
EvaluationStrategy strategy) |
InsertBindingSetCursor(CloseableIteration<BindingSet,QueryEvaluationException> delegate,
BindingSet bindings) |
ParallelJoinCursor(EvaluationStrategy strategy,
CloseableIteration<BindingSet,QueryEvaluationException> leftIter,
TupleExpr rightArg) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends BindingSet,QueryEvaluationException> |
SailConnectionWrapper.evaluate(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
CloseableIteration<? extends BindingSet,QueryEvaluationException> |
SailConnectionBase.evaluate(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
protected abstract CloseableIteration<? extends BindingSet,QueryEvaluationException> |
SailConnectionBase.evaluateInternal(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
CloseableIteration<? extends Resource,SailException> |
SailConnectionWrapper.getContextIDs() |
CloseableIteration<? extends Resource,SailException> |
SailConnectionBase.getContextIDs() |
protected abstract CloseableIteration<? extends Resource,SailException> |
SailConnectionBase.getContextIDsInternal() |
CloseableIteration<? extends Namespace,SailException> |
SailConnectionWrapper.getNamespaces() |
CloseableIteration<? extends Namespace,SailException> |
SailConnectionBase.getNamespaces() |
protected abstract CloseableIteration<? extends Namespace,SailException> |
SailConnectionBase.getNamespacesInternal() |
CloseableIteration<? extends Statement,SailException> |
SailConnectionWrapper.getStatements(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
CloseableIteration<? extends Statement,SailException> |
SailConnectionBase.getStatements(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
protected abstract CloseableIteration<? extends Statement,SailException> |
SailConnectionBase.getStatementsInternal(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
protected <T,E extends Exception> |
SailConnectionBase.registerIteration(CloseableIteration<T,E> iter)
Registers an iteration as active by wrapping it in a
SailBaseIteration object and adding it to the list of active
iterations. |
Modifier and Type | Method and Description |
---|---|
protected <T,E extends Exception> |
SailConnectionBase.registerIteration(CloseableIteration<T,E> iter)
Registers an iteration as active by wrapping it in a
SailBaseIteration object and adding it to the list of active
iterations. |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends BindingSet,QueryEvaluationException> |
InferencerConnectionWrapper.evaluate(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred)
Calls
InferencerConnectionWrapper.flushUpdates() before forwarding the call to the wrapped
connection. |
CloseableIteration<? extends Resource,SailException> |
InferencerConnectionWrapper.getContextIDs()
Calls
InferencerConnectionWrapper.flushUpdates() before forwarding the call to the wrapped
connection. |
CloseableIteration<? extends Statement,SailException> |
InferencerConnectionWrapper.getStatements(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
Resource... contexts)
Calls
InferencerConnectionWrapper.flushUpdates() before forwarding the call to the wrapped
connection. |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends BindingSet,QueryEvaluationException> |
LuceneSailConnection.evaluate(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
Modifier and Type | Class and Description |
---|---|
class |
IteratorCloseableIteration<E,X extends Exception> |
Modifier and Type | Method and Description |
---|---|
protected <X extends Exception> |
MemoryStore.createStatementIterator(Class<X> excClass,
Resource subj,
URI pred,
Value obj,
boolean explicitOnly,
int snapshot,
ReadMode readMode,
Resource... contexts)
Creates a StatementIterator that contains the statements matching the
specified pattern of subject, predicate, object, context.
|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
MemoryStoreConnection.evaluateInternal(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
protected CloseableIteration<? extends Resource,SailException> |
MemoryStoreConnection.getContextIDsInternal() |
protected CloseableIteration<? extends Namespace,SailException> |
MemoryStoreConnection.getNamespacesInternal() |
protected CloseableIteration<? extends Statement,SailException> |
MemoryStoreConnection.getStatementsInternal(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
MemoryStoreConnection.removeIteratorStatements(CloseableIteration<MemStatement,SailException> stIter,
boolean explicit) |
Modifier and Type | Class and Description |
---|---|
class |
MemStatementIterator<X extends Exception>
A StatementIterator that can iterate over a list of Statement objects.
|
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<? extends Statement,IOException> |
NativeStore.createStatementIterator(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
boolean readTransaction,
Resource... contexts)
Creates a statement iterator based on the supplied pattern.
|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
NativeStoreConnection.evaluateInternal(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
protected CloseableIteration<Resource,IOException> |
NativeStore.getContextIDs(boolean readTransaction) |
protected CloseableIteration<? extends Resource,SailException> |
NativeStoreConnection.getContextIDsInternal() |
protected CloseableIteration<? extends Namespace,SailException> |
NativeStoreConnection.getNamespacesInternal() |
CloseableIteration<? extends Statement,QueryEvaluationException> |
NativeTripleSource.getStatements(Resource subj,
URI pred,
Value obj,
Resource... contexts) |
protected CloseableIteration<? extends Statement,SailException> |
NativeStoreConnection.getStatementsInternal(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<int[],IOException> |
StatementList.iteration() |
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<BindingSet,QueryEvaluationException> |
RdbmsConnection.evaluateInternal(TupleExpr expr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
protected CloseableIteration<? extends Namespace,SailException> |
RdbmsConnection.getNamespacesInternal() |
protected CloseableIteration<? extends Statement,SailException> |
RdbmsConnection.getStatementsInternal(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
RdbmsEvaluation.evaluate(TupleExpr expr,
BindingSet bindings) |
CloseableIteration |
RdbmsTripleSource.getStatements(Resource subj,
URI pred,
Value obj,
Resource... contexts) |
Modifier and Type | Class and Description |
---|---|
class |
EmptyRdbmsResourceIteration
Empty iteration that extends
RdbmsResourceIteration . |
class |
EmptyRdbmsStatementIteration
Empty iteration that extends
RdbmsStatementIteration . |
class |
NamespaceIteration
|
class |
RdbmsBindingIteration
Converts a
ResultSet into a BindingSet in an iteration. |
class |
RdbmsResourceIteration
Converts a
ResultSet into a RdbmsResource in an iteration. |
class |
RdbmsStatementIteration
Converts a
ResultSet into a RdbmsStatement in an iteration. |
Modifier and Type | Class and Description |
---|---|
class |
RdbmIterationBase<T,X extends Exception>
Base class for Iteration of a
ResultSet . |
Copyright © 2001-2016 Aduna. All Rights Reserved.