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 |
AbstractCloseableIteration<E,X extends Exception>
Base class for
CloseableIteration s offering common functionality. |
class |
CloseableIterationBase<E,X extends Exception>
Deprecated.
since 2.0. Use
AbstractCloseableIteration instead. |
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 |
IteratorCloseableIteration<E,X extends Exception>
Deprecated.
since 3.0. This feature is for internal use only: its existence, signature or behavior may change without
warning from one release to the next.
|
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 |
QueueIteration<E,T extends Exception>
Makes working with a queue easier by adding the methods
QueueIteration.done() and QueueIteration.toss(Exception) and after
converting the Exception to the required type using QueueIteration.convert(Exception) . |
class |
ReducedIteration<E,X extends Exception>
Removes consecutive duplicates from the object stream.
|
class |
SilentIteration<T,E extends Exception>
An
IterationWrapper that silently ignores any errors that occur during processing. |
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.
|
Constructor and Description |
---|
SilentIteration(CloseableIteration<T,E> iter) |
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
FedXConnection.evaluateInternal(TupleExpr query,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
protected CloseableIteration<? extends Resource,SailException> |
FedXConnection.getContextIDsInternal() |
protected CloseableIteration<? extends Namespace,SailException> |
FedXConnection.getNamespacesInternal() |
protected CloseableIteration<? extends Statement,SailException> |
FedXConnection.getStatementsInternal(Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
CheckStatementPattern.evaluate(BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
ExclusiveStatement.evaluate(BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
StatementTupleExpr.evaluate(BindingSet bindings)
Evaluate this expression using the provided bindings
|
CloseableIteration<BindingSet,QueryEvaluationException> |
ExclusiveGroup.evaluate(BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
StatementSourcePattern.evaluate(BindingSet bindings) |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
StatementSourcePattern.handleStatementSourcePatternCheck(BindingSet bindings) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends Statement,Exception> |
EndpointEntry.getStatements() |
Modifier and Type | Field and Description |
---|---|
protected CloseableIteration<T,QueryEvaluationException> |
TripleSourceBase.ResultHolder.result |
Modifier and Type | Class and Description |
---|---|
class |
FedXQueueCursor<T>
Specialized variants of
QueueCursor which avoids converting any exception if it is already of
typeQueryEvaluationException . |
class |
ParallelExecutorBase<T>
Base class for common parallel executors such as
JoinExecutorBase and UnionExecutorBase . |
class |
ParallelServiceExecutor
Parallel executor for
FedXService nodes, which wrap SERVICE expressions. |
Modifier and Type | Field and Description |
---|---|
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelServiceExecutor.rightIter |
protected CloseableIteration<T,QueryEvaluationException> |
ParallelExecutorBase.rightIter |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<T,QueryEvaluationException> |
ParallelTaskBase.performTask() |
CloseableIteration<T,QueryEvaluationException> |
ParallelTask.performTask() |
protected abstract CloseableIteration<T,QueryEvaluationException> |
ParallelTaskBase.performTaskInternal() |
Modifier and Type | Method and Description |
---|---|
void |
ParallelServiceExecutor.addResult(CloseableIteration<BindingSet,QueryEvaluationException> res) |
void |
ParallelExecutor.addResult(CloseableIteration<T,QueryEvaluationException> res)
Handle the result appropriately, e.g.
|
void |
ParallelExecutorBase.addResult(CloseableIteration<T,QueryEvaluationException> res) |
void |
ControlledWorkerScheduler.handleResult(CloseableIteration<T,QueryEvaluationException> res) |
void |
Scheduler.handleResult(CloseableIteration<T,QueryEvaluationException> res)
Callback to handle the result.
|
Modifier and Type | Class and Description |
---|---|
class |
BoundJoinConversionIteration
Inserts original bindings into the result.
|
class |
BoundJoinVALUESConversionIteration
Inserts original bindings into the result.
|
class |
CloseDependentConnectionIteration<T>
A wrapping iteration that attempts to close the dependent
RepositoryConnection after consumption. |
class |
ConsumingIteration
A specialized
CloseableIteration that consumes part (or the entire input iteration if it fits into the
buffer) and keeps data for further processing in memory. |
class |
FilteringInsertBindingsIteration
Filters iteration according to specified filterExpr and inserts original bindings into filtered results.
|
class |
GraphToBindingSetConversionIteration
Converts graph results into a binding set iteration
|
class |
GroupedCheckConversionIteration
Retrieves the original bindings for the particular result
|
class |
IndependentJoingroupBindingsIteration
Inserts original bindings into the result.
|
class |
IndependentJoingroupBindingsIteration2
Inserts original bindings into the result.
|
class |
IndependentJoingroupBindingsIteration3
Inserts original bindings into the result.
|
class |
InsertBindingsIteration
Inserts original bindings into the result.
|
class |
LazyMutableClosableIteration
A specialized
CloseableIteration that allows repetitive iterations after resetting the cursor using
LazyMutableClosableIteration.resetCursor() . |
class |
PrintingIteration
Print the bindings of the inner iteration to stdout, however maintain a copy, which is accessible through this
iteration.
|
class |
QueryResultIteration
An iteration which wraps the final result and in case of exceptions aborts query evaluation for the corresponding
query in fedx (potentially subqueries are still running, and jobs are scheduled).
|
class |
RepositoryExceptionConvertingIteration<T>
Convenience iteration to convert
RepositoryResult exceptions to QueryEvaluationException . |
class |
SingleBindingSetIteration
Represents an iteration that contains only a single binding set.
|
class |
StatementConversionIteration
Converts Statement iteration (i.e.
|
class |
StopRemainingExecutionsOnCloseIteration
A wrapping iteration that attempts to close all running scheduled
Future s for the given query evaluation. |
Modifier and Type | Field and Description |
---|---|
protected CloseableIteration<BindingSet,QueryEvaluationException> |
LazyMutableClosableIteration.inner |
protected CloseableIteration<T,QueryEvaluationException> |
CloseDependentConnectionIteration.inner |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
PrintingIteration.inner |
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
StopRemainingExecutionsOnCloseIteration.inner |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
QueryResultIteration.inner |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
IndependentJoingroupBindingsIteration.iter |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
IndependentJoingroupBindingsIteration2.iter |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
IndependentJoingroupBindingsIteration3.iter |
Modifier and Type | Class and Description |
---|---|
class |
ControlledWorkerBoundJoin
Execute the nested loop join in an asynchronous fashion, using grouped requests, i.e.
|
class |
ControlledWorkerJoin
Execute the nested loop join in an asynchronous fashion, i.e.
|
class |
ControlledWorkerLeftJoin
Execute the nested loop join in an asynchronous fashion, i.e.
|
class |
HashJoin
Operator for a hash join of tuple expressions.
|
class |
SynchronousBoundJoin
Execute the nested loop join in a synchronous fashion, using grouped requests, i.e.
|
class |
SynchronousJoin
Execute the nested loop join in a synchronous fashion, i.e.
|
Modifier and Type | Field and Description |
---|---|
protected CloseableIteration<T,QueryEvaluationException> |
JoinExecutorBase.leftIter |
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelJoinTask.performTaskInternal() |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelLeftJoinTask.performTaskInternal() |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelServiceJoinTask.performTaskInternal() |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelBoundJoinTask.performTaskInternal() |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelCheckJoinTask.performTaskInternal() |
Modifier and Type | Class and Description |
---|---|
class |
ControlledWorkerUnion<T>
Execution of union tasks with
ControlledWorkerScheduler . |
class |
SynchronousWorkerUnion<T>
Synchronous execution of union tasks, i.e.
|
class |
UnionExecutorBase<T>
Base class for any parallel union executor.
|
class |
WorkerUnionBase<T>
Base class for worker unions providing convenience functions to add tasks.
|
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelUnionTask.performTaskInternal() |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelPreparedUnionTask.performTaskInternal() |
protected CloseableIteration<Statement,QueryEvaluationException> |
ParallelGetStatementsTask.performTaskInternal() |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelPreparedAlgebraUnionTask.performTaskInternal() |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
ParallelUnionOperatorTask.performTaskInternal() |
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<BindingSet,QueryEvaluationException> |
SourceSelection.ParallelCheckTask.performTaskInternal() |
Modifier and Type | Method and Description |
---|---|
void |
SourceSelection.SourceSelectionExecutorWithLatch.addResult(CloseableIteration<BindingSet,QueryEvaluationException> res) |
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 |
---|---|
static Model |
QueryResults.asModel(CloseableIteration<? extends Statement,? extends RDF4JException> iteration)
Get a
Model containing all elements obtained from the specified query result. |
static Model |
QueryResults.asModel(CloseableIteration<? extends Statement,? extends RDF4JException> iteration,
ModelFactory modelFactory)
Get a
Model containing all elements obtained from the specified query result. |
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.
|
protected abstract CloseableIteration<? extends BindingSet,QueryEvaluationException> |
AbstractQueryPreparer.evaluate(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred,
int maxExecutionTime) |
CloseableIteration<? extends Triple,QueryEvaluationException> |
RDFStarTripleSource.getRdfStarTriples(Resource subj,
IRI pred,
Value obj)
Gets all Triple nodes that have a specific subject, predicate and/or object.
|
CloseableIteration<? extends Statement,QueryEvaluationException> |
TripleSource.getStatements(Resource subj,
IRI 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 |
ServiceCrossProductIteration
Deprecated.
|
class |
ServiceJoinIterator
Iterator for efficient SERVICE evaluation (vectored).
|
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
TupleFunctionFederatedService.evaluate(Service service,
CloseableIteration<BindingSet,QueryEvaluationException> bindings,
String baseUri) |
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> |
TupleFunctionFederatedService.select(Service service,
Set<String> projectionVars,
BindingSet bindings,
String baseUri) |
CloseableIteration<BindingSet,QueryEvaluationException> |
FederatedService.select(Service service,
Set<String> projectionVars,
BindingSet bindings,
String baseUri)
Evaluate the provided SPARQL query at this federated service.
|
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
TupleFunctionFederatedService.evaluate(Service service,
CloseableIteration<BindingSet,QueryEvaluationException> bindings,
String baseUri) |
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.
|
Constructor and Description |
---|
JoinExecutorBase(CloseableIteration<T,QueryEvaluationException> leftIter,
TupleExpr rightArg,
BindingSet bindings)
Deprecated.
|
ServiceCrossProductIteration(CloseableIteration<BindingSet,QueryEvaluationException> resultIteration,
List<BindingSet> inputBindings)
Deprecated.
|
ServiceJoinConversionIteration(CloseableIteration<BindingSet,QueryEvaluationException> iter,
List<BindingSet> bindings)
Deprecated.
|
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<? extends List<? extends Value>,QueryEvaluationException> |
TupleFunction.evaluate(ValueFactory valueFactory,
Value... args) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
StrictEvaluationStrategy.evaluate(Service service,
String serviceUri,
CloseableIteration<BindingSet,QueryEvaluationException> bindings) |
Modifier and Type | Class and Description |
---|---|
class |
BadlyDesignedLeftJoinIterator |
class |
BottomUpJoinIterator
Deprecated.
replaced by HashJoinIteration
|
class |
CompatibleBindingSetFilter
Deprecated.
|
class |
CrossProductIteration
Iteration which forms the cross product of a list of materialized input bindings with each result obtained from the
inner iteration.
|
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
Interleaved join iterator.
|
class |
LeftJoinIterator |
class |
MultiProjectionIterator |
class |
OrderIterator
Sorts the input and optionally applies limit and distinct.
|
class |
PathIteration |
class |
ProjectionIterator |
class |
QueryContextIteration
Makes a
QueryContext available during iteration. |
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> |
CrossProductIteration.resultIteration |
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 | Method and Description |
---|---|
static CloseableIteration<Literal,QueryEvaluationException> |
TripleSources.getObjectLiterals(Resource subject,
IRI predicate,
TripleSource store) |
static CloseableIteration<Resource,QueryEvaluationException> |
TripleSources.getObjectResources(Resource subject,
IRI predicate,
TripleSource store) |
static CloseableIteration<IRI,QueryEvaluationException> |
TripleSources.getObjectURIs(Resource subject,
IRI predicate,
TripleSource store) |
static CloseableIteration<IRI,QueryEvaluationException> |
TripleSources.getSubjectURIs(IRI predicate,
Value object,
TripleSource store) |
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractParserQuery.QueryInterruptIteration |
class |
BackgroundGraphResult
Provides concurrent access to statements as they are being parsed when instances of this class are run as Threads.
|
class |
GraphQueryResultImpl
Deprecated.
since 2.0. Use
IteratingGraphQueryResult instead. |
class |
IteratingGraphQueryResult
An iterating implementation of the
GraphQueryResult interface. |
class |
IteratingTupleQueryResult
An iterating implementation of the
TupleQueryResult interface. |
class |
MutableTupleQueryResult
An implementation of the
TupleQueryResult interface that stores the complete query result in memory. |
class |
QueueCursor<E>
Makes working with a queue easier by adding the methods
QueueIteration.done() and QueueIteration.toss(Exception) and
automatically converting the exception into a QueryEvaluationException with an appropriate stack trace. |
class |
TupleQueryResultImpl
Deprecated.
since 2.0. Use
IteratingTupleQueryResult instead. |
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
AbstractParserQuery.enforceMaxQueryTime(CloseableIteration<? extends BindingSet,QueryEvaluationException> bindingsIter) |
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
AbstractParserQuery.enforceMaxQueryTime(CloseableIteration<? extends BindingSet,QueryEvaluationException> bindingsIter) |
Constructor and Description |
---|
GraphQueryResultImpl(Map<String,String> namespaces,
CloseableIteration<? extends Statement,? extends QueryEvaluationException> statementIter)
Deprecated.
|
IteratingGraphQueryResult(Map<String,String> namespaces,
CloseableIteration<? extends Statement,? extends QueryEvaluationException> statementIter) |
IteratingTupleQueryResult(List<String> bindingNames,
CloseableIteration<? extends BindingSet,QueryEvaluationException> bindingSetIter)
Creates a query result object with the supplied binding names.
|
TupleQueryResultImpl(List<String> bindingNames,
CloseableIteration<? extends BindingSet,QueryEvaluationException> bindingSetIter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
AbstractParserQuery.enforceMaxQueryTime(CloseableIteration<? extends BindingSet,QueryEvaluationException> bindingsIter) |
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
AbstractParserQuery.enforceMaxQueryTime(CloseableIteration<? extends BindingSet,QueryEvaluationException> bindingsIter) |
Modifier and Type | Class and Description |
---|---|
class |
BackgroundTupleResult
Provides concurrent access to tuple results as they are being parsed.
|
Modifier and Type | Class and Description |
---|---|
class |
RepositoryResult<T>
|
Constructor and Description |
---|
RepositoryResult(CloseableIteration<? extends T,RepositoryException> iter) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends Statement,QueryEvaluationException> |
RepositoryTripleSource.getStatements(Resource subj,
IRI pred,
Value obj,
Resource... contexts) |
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
|
Modifier and Type | Class and Description |
---|---|
class |
CollectionIteration<E,X extends Exception>
An iteration to access a materialized
Collection of BindingSets. |
class |
JoinExecutorBase<T>
Base class for any join parallel join executor.
|
class |
ServiceJoinConversionIteration
Inserts original bindings into the result, uses ?__rowIdx to resolve original bindings.
|
class |
SPARQLCrossProductIteration
Iteration which forms the cross product of a list of materialized input bindings with each result obtained from the
inner iteration.
|
Modifier and Type | Field and Description |
---|---|
protected CloseableIteration<T,QueryEvaluationException> |
JoinExecutorBase.leftIter |
protected CloseableIteration<BindingSet,QueryEvaluationException> |
SPARQLCrossProductIteration.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> |
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> |
RepositoryFederatedService.select(Service service,
Set<String> projectionVars,
BindingSet bindings,
String baseUri)
Evaluate the provided sparqlQueryString at the initialized
Repository of this FederatedService . |
Modifier and Type | Method and Description |
---|---|
void |
JoinExecutorBase.addResult(CloseableIteration<T,QueryEvaluationException> res) |
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 . |
Constructor and Description |
---|
JoinExecutorBase(CloseableIteration<T,QueryEvaluationException> leftIter,
TupleExpr rightArg,
BindingSet bindings) |
ServiceJoinConversionIteration(CloseableIteration<BindingSet,QueryEvaluationException> iter,
List<BindingSet> bindings) |
SilentIteration(CloseableIteration<BindingSet,QueryEvaluationException> iter)
Deprecated.
|
SPARQLCrossProductIteration(CloseableIteration<BindingSet,QueryEvaluationException> resultIteration,
List<BindingSet> inputBindings) |
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,
IRI pred,
Value obj,
boolean includeInferred,
Resource... contexts)
Gets all statements from the specified contexts that have a specific subject, predicate and/or object.
|
default CloseableIteration<? extends Statement,SailException> |
SailConnection.getStatements(Resource subj,
URI pred,
Value obj,
boolean includeInferred,
Resource... contexts)
Deprecated.
since 4.0. Use
SailConnection.getStatements(Resource, IRI, Value, boolean, Resource...) instead. |
Modifier and Type | Class and Description |
---|---|
class |
DistinctModelReducingUnionIteration
An Iteration that takes two source.
|
Modifier and Type | Method and Description |
---|---|
protected CloseableIteration<? extends BindingSet,QueryEvaluationException> |
SailSourceConnection.evaluateInternal(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
CloseableIteration<? extends Resource,SailException> |
SailDataset.getContextIDs()
Returns the set of all unique context identifiers that are used to store statements.
|
protected CloseableIteration<? extends Resource,SailException> |
SailSourceConnection.getContextIDsInternal() |
CloseableIteration<? extends Namespace,SailException> |
SailDataset.getNamespaces()
Gets the namespaces relevant to the data contained in this object.
|
protected CloseableIteration<? extends Namespace,SailException> |
SailSourceConnection.getNamespacesInternal() |
CloseableIteration<? extends Statement,SailException> |
SailDataset.getStatements(Resource subj,
IRI pred,
Value obj,
Resource... contexts)
Gets all statements that have a specific subject, predicate and/or object.
|
protected CloseableIteration<? extends Statement,SailException> |
SailSourceConnection.getStatementsInternal(Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
default CloseableIteration<? extends Triple,SailException> |
SailDataset.getTriples(Resource subj,
IRI pred,
Value obj)
Gets all RDF-star triples that have a specific subject, predicate and/or object.
|
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends Statement,QueryEvaluationException> |
SailTripleSource.getStatements(Resource subj,
IRI pred,
Value obj,
Resource... contexts) |
Modifier and Type | Class and Description |
---|---|
class |
FilteringIteration<E extends ExtensibleStatement,X extends Exception>
A wrapper for an Iteration that filters the statements against a pattern similar to getStatements(Resource subject,
IRI predicate, Value object, Resource...
|
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends ExtensibleStatement,SailException> |
ReadCache.getStatements(Resource subject,
IRI predicate,
Value object,
boolean inferred,
Resource... context) |
CloseableIteration<? extends ExtensibleStatement,SailException> |
DataStructureInterface.getStatements(Resource subject,
IRI predicate,
Value object,
boolean inferred,
Resource... context) |
Constructor and Description |
---|
FilteringIteration(CloseableIteration<E,X> wrappedIteration,
Resource subject,
IRI predicate,
Value object,
boolean inferred,
Resource... context) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends ExtensibleStatement,SailException> |
EvaluationStatisticsWrapper.getStatements(Resource subject,
IRI predicate,
Value object,
boolean inferred,
Resource... context) |
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) |
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> |
AbstractSailConnection.evaluate(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
protected abstract CloseableIteration<? extends BindingSet,QueryEvaluationException> |
AbstractSailConnection.evaluateInternal(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred) |
CloseableIteration<? extends Resource,SailException> |
SailConnectionWrapper.getContextIDs() |
CloseableIteration<? extends Resource,SailException> |
AbstractSailConnection.getContextIDs() |
protected abstract CloseableIteration<? extends Resource,SailException> |
AbstractSailConnection.getContextIDsInternal() |
CloseableIteration<? extends Namespace,SailException> |
SailConnectionWrapper.getNamespaces() |
CloseableIteration<? extends Namespace,SailException> |
AbstractSailConnection.getNamespaces() |
protected abstract CloseableIteration<? extends Namespace,SailException> |
AbstractSailConnection.getNamespacesInternal() |
CloseableIteration<? extends Statement,SailException> |
SailConnectionWrapper.getStatements(Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
CloseableIteration<? extends Statement,SailException> |
AbstractSailConnection.getStatements(Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
protected abstract CloseableIteration<? extends Statement,SailException> |
AbstractSailConnection.getStatementsInternal(Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
protected <T,E extends Exception> |
AbstractSailConnection.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> |
AbstractSailConnection.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,
IRI 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 | Method and Description |
---|---|
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
QueryTupleFunction.evaluate(ValueFactory valueFactory,
Value... args)
Deprecated.
|
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
DistanceTupleFunction.evaluate(ValueFactory valueFactory,
Value... args)
Deprecated.
|
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 | Class and Description |
---|---|
class |
CloseablePeakableIteration<E,X extends Exception> |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends Statement,SailException> |
ShaclSailConnection.getStatements(Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
CloseableIteration<? extends Statement,SailException> |
VerySimpleRdfsBackwardsChainingConnection.getStatements(Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
Constructor and Description |
---|
CloseablePeakableIteration(CloseableIteration<E,X> parent) |
Constructor and Description |
---|
ValidationResultIterator(CloseableIteration<? extends org.eclipse.rdf4j.sail.shacl.ast.planNodes.ValidationTuple,SailException> tupleIterator,
long limit) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
ConstructTupleFunction.evaluate(ValueFactory valueFactory,
Value... args) |
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
SelectTupleFunction.evaluate(ValueFactory valueFactory,
Value... args) |
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
SpinTupleFunction.evaluate(ValueFactory valueFactory,
Value... args) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
ConcatTupleFunction.evaluate(ValueFactory valueFactory,
Value... args) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
Index.evaluate(ValueFactory valueFactory,
Value... args) |
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
Length.evaluate(ValueFactory valueFactory,
Value... args) |
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
Member.evaluate(ValueFactory valueFactory,
Value... args) |
Modifier and Type | Method and Description |
---|---|
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
Split.evaluate(ValueFactory valueFactory,
Value... args) |
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
For.evaluate(ValueFactory valueFactory,
Value... args) |
CloseableIteration<? extends List<? extends Value>,QueryEvaluationException> |
ForEach.evaluate(ValueFactory valueFactory,
Value... args) |
Copyright © 2015-2022 Eclipse Foundation. All Rights Reserved.