Uses of Interface
org.eclipse.rdf4j.common.iteration.CloseableIteration
Package
Description
Package offering various locking scheme implementations.
Interfaces and classes for handling queries and query results.
Abstract Query Algebra model.
Implementations of
relevant to query evaluation.
invalid reference
Iteration
The Repository API: the main API for accessing rdf databases and SPARQL endpoints.
Abstract base classes and wrappers for the main Repository API interfaces.
A repository wrapper with convenience functions for handling contexts.
Repository implementation for local RDF databases that implement the SAIL SPI.
RDF Storage And Inference Layer (RDF Sail): a set of interfaces defining an SPI for RDF databases.
Base functionality for Sail implementations that require multi-versioned concurrency control (MVCC).
Elasticsearch store for string triples
Abstract base implementation and internal helper classes for Sail implementations.
The LMDB based Store.
A Sail implementation that supports full-text indexing via the Lucene API.
MemoryStore-specific implementations of the core RDF model objects.
A Sail implementation for SHACL constraint checking.
Core functions required for SPIN.
Rdf4j-Spring OperationLog
Rdf4j-Spring ResultCache
Rdf4J-Spring Tx
-
Uses of CloseableIteration in org.eclipse.rdf4j.common.concurrent.locks
Modifier and TypeClassDescriptionclass
An Iteration that holds on to a lock until the Iteration is closed.Modifier and TypeMethodDescriptionstatic <T,
R extends Exception>
CloseableIteration<T> LockingIteration.getInstance
(Lock lock, CloseableIteration<T> iter) Modifier and TypeMethodDescriptionstatic <T,
R extends Exception>
CloseableIteration<T> LockingIteration.getInstance
(Lock lock, CloseableIteration<T> iter) -
Uses of CloseableIteration in org.eclipse.rdf4j.common.concurrent.locks.diagnostics
-
Uses of CloseableIteration in org.eclipse.rdf4j.common.iteration
Modifier and TypeClassDescriptionclass
Base class forCloseableIteration
s offering common functionality.class
An Iteration that can convert anIterator
to aCloseableIteration
.class
An Iteration that can convert anIterator
to aCloseableIteration
.class
ConvertingIteration<S,
T> 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
An iteration that delays the creation of the underlying iteration until it is being accessed.class
An Iteration that filters any duplicate elements from an underlying iterator.class
Provides a bag union of the two provided iterations.final class
An iterator that does not contain any elements.class
ExceptionConvertingIteration<E,
X extends RuntimeException> Deprecated.class
A CloseableIteration that wraps another Iteration, applying a filter on the objects that are returned.class
An Iteration that returns the intersection of the results of two Iterations.class
Deprecated.class
An Iteration that limits the amount of elements that it returns from an underlying Iteration to a fixed amount.class
An Iteration that looks one element ahead, if necessary, to handle calls toLookAheadIteration.hasNext()
.class
An Iteration that returns the results of an Iteration (the left argument) minus the results of another Iteration (the right argument).class
An Iteration that skips the first offset elements from an underlying Iteration.class
QueueIteration<E,
T extends RuntimeException> Makes working with a queue easier by adding the methodsQueueIteration.done()
andQueueIteration.toss(Exception)
and after converting the Exception to the required type usingQueueIteration.convert(Exception)
.class
Removes consecutive duplicates from the object stream.class
AnIterationWrapper
that silently ignores any errors that occur during processing.class
An Iteration that contains exactly one element.class
An iteration that delays the creation of the underlying iteration until it is being accessed.class
class
An Iteration that returns the bag union of the results of a number of Iterations.Modifier and TypeFieldDescriptionprotected final CloseableIteration
<? extends E> IntersectIteration.arg2
protected final CloseableIteration
<? extends E> IterationWrapper.wrappedIter
Deprecated.This will be changed to private, possibly with an accessor in future.Modifier and TypeMethodDescriptionprotected abstract CloseableIteration
<? extends E> DelayedIteration.createIteration()
Creates the iteration that should be iterated over.protected abstract CloseableIteration
<? extends E> ThreadSafeDelayedIteration.createIteration()
Creates the iteration that should be iterated over.static <E> CloseableIteration
<E> DualUnionIteration.getInstance
(CloseableIteration<E> leftIteration, CloseableIteration<E> rightIteration) static <E> CloseableIteration
<? extends E> DualUnionIteration.getWildcardInstance
(Comparator<E> cmp, CloseableIteration<? extends E> leftIteration, CloseableIteration<? extends E> rightIteration) static <E> CloseableIteration
<? extends E> DualUnionIteration.getWildcardInstance
(CloseableIteration<? extends E> leftIteration, CloseableIteration<? extends E> rightIteration) Modifier and TypeMethodDescriptionstatic <E,
C extends Collection<E>>
CIterations.addAll
(CloseableIteration<? extends E> iteration, C collection) Adds all elements from the suppliedCloseableIteration
to the specified collection then closes theCloseableIteration
.static <E> List
<E> Iterations.asList
(CloseableIteration<? extends E> iteration) Get a List containing all elements obtained from the specified iteration.static <E> Set
<E> Iterations.asSet
(CloseableIteration<? extends E> iteration) Get a Set containing all elements obtained from the specified iteration.static <E> Set
<E> Iterations.asSet
(CloseableIteration<? extends E> iteration, Supplier<Set<E>> setMaker) Get a Set containing all elements obtained from the specified iteration.static <E> CloseableIteration
<E> DualUnionIteration.getInstance
(CloseableIteration<E> leftIteration, CloseableIteration<E> rightIteration) static <E> CloseableIteration
<? extends E> DualUnionIteration.getWildcardInstance
(Comparator<E> cmp, CloseableIteration<? extends E> leftIteration, CloseableIteration<? extends E> rightIteration) static <E> CloseableIteration
<? extends E> DualUnionIteration.getWildcardInstance
(CloseableIteration<? extends E> leftIteration, CloseableIteration<? extends E> rightIteration) static <T> Stream
<T> Iterations.stream
(CloseableIteration<T> iteration) Get a sequentialStream
with the suppliedCloseableIteration
as its source.static String
Iterations.toString
(CloseableIteration<?> iteration, String separator) Converts aCloseableIteration
to a string by concatenating all the string representations of objects in the iteration, divided by a separator.static void
Iterations.toString
(CloseableIteration<?> iteration, String separator, StringBuilder sb) Converts aCloseableIteration
to a string by concatenating all the string representations of objects in the iteration, divided by a separator.ModifierConstructorDescriptionprotected
ConvertingIteration
(CloseableIteration<? extends S> iter) Creates a new ConvertingIteration that operates on the supplied source type iteration.DistinctIteration
(CloseableIteration<? extends E> iter) Deprecated.DistinctIteration
(CloseableIteration<? extends E> iter, Supplier<Set<E>> setMaker) Creates a new DistinctIterator.DistinctIteration
(CloseableIteration<? extends E> iter, Set<E> excludeSet) Creates a new DistinctIterator.DualUnionIteration
(Comparator<E> cmp, CloseableIteration<? extends E> iteration1, CloseableIteration<? extends E> iteration2) protected
ExceptionConvertingIteration
(CloseableIteration<? extends E> iter) Deprecated.Creates a new ExceptionConvertingIteration that operates on the supplied iteration.protected
FilterIteration
(CloseableIteration<? extends E> iter) IntersectIteration
(CloseableIteration<? extends E> arg1, CloseableIteration<? extends E> arg2) Creates a new IntersectIteration that returns the intersection of the results of two Iterations.IntersectIteration
(CloseableIteration<? extends E> arg1, CloseableIteration<? extends E> arg2, boolean distinct) Creates a new IntersectIteration that returns the intersection of the results of two Iterations.IntersectIteration
(CloseableIteration<? extends E> arg1, CloseableIteration<? extends E> arg2, boolean distinct, Supplier<Set<E>> setMaker) Creates a new IntersectIteration that returns the intersection of the results of two Iterations.IntersectIteration
(CloseableIteration<? extends E> arg1, CloseableIteration<? extends E> arg2, Supplier<Set<E>> setMaker) protected
IterationWrapper
(CloseableIteration<? extends E> iter) Deprecated.Creates a new IterationWrapper that operates on the supplied Iteration.LimitIteration
(CloseableIteration<? extends E> iter, long limit) Creates a new LimitIteration.MinusIteration
(CloseableIteration<? extends E> leftArg, CloseableIteration<? extends E> rightArg) Creates a new MinusIteration that returns the results of the left argument minus the results of the right argument.MinusIteration
(CloseableIteration<? extends E> leftArg, CloseableIteration<? extends E> rightArg, boolean distinct) Creates a new MinusIteration that returns the results of the left argument minus the results of the right argument.MinusIteration
(CloseableIteration<? extends E> leftArg, CloseableIteration<? extends E> rightArg, boolean distinct, Supplier<Set<E>> setMaker) Creates a new MinusIteration that returns the results of the left argument minus the results of the right argument.OffsetIteration
(CloseableIteration<? extends E> iter, long offset) Creates a new OffsetIteration.ReducedIteration
(CloseableIteration<? extends E> delegate) SilentIteration
(CloseableIteration<T> iter) protected
TimeLimitIteration
(CloseableIteration<? extends E> iter, long timeLimit) UnionIteration
(CloseableIteration<? extends E>... args) Creates a new UnionIteration that returns the bag union of the results of a number of Iterations.ModifierConstructorDescriptionUnionIteration
(Iterable<? extends CloseableIteration<? extends E>> args) Creates a new UnionIteration that returns the bag union of the results of a number of Iterations. -
Uses of CloseableIteration in org.eclipse.rdf4j.common.iterator
ModifierConstructorDescriptionCloseableIterationIterator
(CloseableIteration<? extends E> iteration) -
Uses of CloseableIteration in org.eclipse.rdf4j.federated
Modifier and TypeMethodDescriptionprotected CloseableIteration
<? extends BindingSet> FedXConnection.evaluateInternal
(TupleExpr query, Dataset dataset, BindingSet bindings, boolean includeInferred) protected CloseableIteration
<? extends Resource> FedXConnection.getContextIDsInternal()
protected CloseableIteration
<? extends Namespace> FedXConnection.getNamespacesInternal()
protected CloseableIteration
<? extends Statement> FedXConnection.getStatementsInternal
(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) -
Uses of CloseableIteration in org.eclipse.rdf4j.federated.algebra
Modifier and TypeMethodDescriptionCheckStatementPattern.evaluate
(BindingSet bindings) ExclusiveGroup.evaluate
(BindingSet bindings) ExclusiveStatement.evaluate
(BindingSet bindings) StatementSourcePattern.evaluate
(BindingSet bindings) StatementTupleExpr.evaluate
(BindingSet bindings) Evaluate this expression using the provided bindingsprotected CloseableIteration
<BindingSet> StatementSourcePattern.handleStatementSourcePatternCheck
(BindingSet bindings) -
Uses of CloseableIteration in org.eclipse.rdf4j.federated.cache
Modifier and TypeMethodDescriptionCloseableIteration
<? extends Statement> EndpointEntry.getStatements()
-
Uses of CloseableIteration in org.eclipse.rdf4j.federated.evaluation
Modifier and TypeFieldDescriptionprotected CloseableIteration
<T> TripleSourceBase.ResultHolder.result
Modifier and TypeMethodDescriptionFederationEvalStrategy.evaluate
(DescribeOperator operator, BindingSet bindings) FederationEvalStrategy.evaluate
(TupleExpr expr, BindingSet bindings) Deprecated, for removal: This API element is subject to removal in a future version.FedXZeroLengthPathEvaluationStep.evaluate
(BindingSet bindings) protected CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateArbitrayLengthPath
(FedXArbitraryLengthPath alp, BindingSet bindings) protected CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateAtStatementSources
(Object preparedQuery, List<StatementSource> statementSources, QueryInfo queryInfo) protected CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateAtStatementSources
(String preparedQuery, List<StatementSource> statementSources, QueryInfo queryInfo) protected CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateAtStatementSources
(TupleExpr preparedQuery, List<StatementSource> statementSources, QueryInfo queryInfo) abstract CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateBoundJoinStatementPattern
(StatementTupleExpr stmt, List<BindingSet> bindings) Evaluate a bound join at the relevant endpoint, i.e.SailFederationEvalStrategy.evaluateBoundJoinStatementPattern
(StatementTupleExpr stmt, List<BindingSet> bindings) SparqlFederationEvalStrategy.evaluateBoundJoinStatementPattern
(StatementTupleExpr stmt, List<BindingSet> bindings) protected CloseableIteration
<BindingSet> SparqlFederationEvalStrategy.evaluateBoundJoinStatementPattern_UNION
(StatementTupleExpr stmt, List<BindingSet> bindings) Deprecated, for removal: This API element is subject to removal in a future version.no longer usedabstract CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateExclusiveGroup
(ExclusiveGroup group, BindingSet bindings) SailFederationEvalStrategy.evaluateExclusiveGroup
(ExclusiveGroup group, BindingSet bindings) SparqlFederationEvalStrategy.evaluateExclusiveGroup
(ExclusiveGroup group, BindingSet bindings) protected CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateExclusiveTupleExpr
(ExclusiveTupleExpr expr, BindingSet bindings) Evaluate anExclusiveTupleExpr
.abstract CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateGroupedCheck
(CheckStatementPattern stmt, List<BindingSet> bindings) Deprecated, for removal: This API element is subject to removal in a future version.with VALUES implementation, control flow goes viaFederationEvalStrategy.evaluateBoundJoinStatementPattern(StatementTupleExpr, List)
SailFederationEvalStrategy.evaluateGroupedCheck
(CheckStatementPattern stmt, List<BindingSet> bindings) SparqlFederationEvalStrategy.evaluateGroupedCheck
(CheckStatementPattern stmt, List<BindingSet> bindings) FederationEvalStrategy.evaluateLeftBoundJoinStatementPattern
(StatementTupleExpr stmt, List<BindingSet> bindings) Evaluate the left bind join for the givenStatementTupleExpr
and bindings at the relevant endpoints.protected CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateLeftJoin
(FedXLeftJoin leftJoin, BindingSet bindings) Evaluate aFedXLeftJoin
(i.e.FederationEvalStrategy.evaluateNaryUnion
(NUnion union, BindingSet bindings) FederationEvalStrategy.evaluateNJoin
(NJoin join, BindingSet bindings) FederationEvalStrategy.evaluateService
(FedXService service, List<BindingSet> bindings) Evaluate a SERVICE using vectored evaluation, taking the provided bindings as input.FederationEvalStrategy.evaluateService
(FedXService service, BindingSet bindings) FederationEvalStrategy.evaluateSingleSourceQuery
(SingleSourceQuery query, BindingSet bindings) protected CloseableIteration
<BindingSet> FederationEvalStrategy.evaluateZeroLengthPath
(FedXZeroLengthPath zlp, BindingSet bindings) protected abstract CloseableIteration
<BindingSet> FederationEvalStrategy.executeJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVariables, BindingSet bindings, QueryInfo queryInfo) Execute the join in a separate thread using some join executor.SailFederationEvalStrategy.executeJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo) SparqlFederationEvalStrategy.executeJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo) protected abstract CloseableIteration
<BindingSet> FederationEvalStrategy.executeLeftJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo) Execute the left join in a separate thread using some join executor.protected CloseableIteration
<BindingSet> SailFederationEvalStrategy.executeLeftJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo) protected CloseableIteration
<BindingSet> SparqlFederationEvalStrategy.executeLeftJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo) TripleSourceBase.ResultHolder.get()
FederationEvalStrategy.getStatements
(QueryInfo queryInfo, Resource subj, IRI pred, Value obj, Resource... contexts) Retrieve the statements matching the provided subject, predicate and object value from the federation members.SailTripleSource.getStatements
(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts) SailTripleSource.getStatements
(StatementPattern stmt, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo) SailTripleSource.getStatements
(TupleExpr preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo) SparqlTripleSource.getStatements
(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts) SparqlTripleSource.getStatements
(StatementPattern stmt, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo) SparqlTripleSource.getStatements
(TupleExpr preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo) TripleSource.getStatements
(String preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo) Evaluate the prepared query (SPARQL query as String) on the provided endpoint.TripleSource.getStatements
(String preparedQuery, BindingSet queryBindings, QueryType queryType, QueryInfo queryInfo) Evaluate a given SPARQL query of the provided query type at the given source.TripleSource.getStatements
(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts) Return the statements matching the given pattern as aStatement
iteration.TripleSource.getStatements
(StatementPattern stmt, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo) Evaluate the query expression on the provided endpoint.TripleSource.getStatements
(TupleExpr preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo) Evaluate the prepared query in its internal representation on the provided endpoint.TripleSourceBase.getStatements
(String preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo) TripleSourceBase.getStatements
(String preparedQuery, BindingSet queryBindings, QueryType queryType, QueryInfo queryInfo) protected <T> CloseableIteration
<T> TripleSourceBase.withConnection
(TripleSourceBase.ConnectionOperation<T> operation) Convenience method to perform an operation on aRepositoryConnection
.Modifier and TypeMethodDescriptionprotected abstract CloseableIteration
<BindingSet> FederationEvalStrategy.executeJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVariables, BindingSet bindings, QueryInfo queryInfo) Execute the join in a separate thread using some join executor.SailFederationEvalStrategy.executeJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo) SparqlFederationEvalStrategy.executeJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo) protected abstract CloseableIteration
<BindingSet> FederationEvalStrategy.executeLeftJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo) Execute the left join in a separate thread using some join executor.protected CloseableIteration
<BindingSet> SailFederationEvalStrategy.executeLeftJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo) protected CloseableIteration
<BindingSet> SparqlFederationEvalStrategy.executeLeftJoin
(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo) void
TripleSourceBase.ResultHolder.set
(CloseableIteration<T> result) -
Uses of CloseableIteration in org.eclipse.rdf4j.federated.evaluation.concurrent
Modifier and TypeClassDescriptionclass
Specialized variants ofQueueCursor
which avoids converting any exception if it is already of typeQueryEvaluationException
.class
Base class for common parallel executors such asJoinExecutorBase
andUnionExecutorBase
.class
Parallel executor forFedXService
nodes, which wrap SERVICE expressions.Modifier and TypeFieldDescriptionprotected CloseableIteration
<T> ParallelExecutorBase.rightIter
protected CloseableIteration
<BindingSet> ParallelServiceExecutor.rightIter
Modifier and TypeMethodDescriptionParallelTask.performTask()
ParallelTaskBase.performTask()
protected abstract CloseableIteration
<T> ParallelTaskBase.performTaskInternal()
Modifier and TypeMethodDescriptionvoid
ParallelExecutor.addResult
(CloseableIteration<T> res) Handle the result appropriately, e.g.void
ParallelExecutorBase.addResult
(CloseableIteration<T> res) void
ParallelServiceExecutor.addResult
(CloseableIteration<BindingSet> res) void
ControlledWorkerScheduler.handleResult
(CloseableIteration<T> res) void
Scheduler.handleResult
(CloseableIteration<T> res) Callback to handle the result. -
Uses of CloseableIteration in org.eclipse.rdf4j.federated.evaluation.iterator
Modifier and TypeClassDescriptionclass
ALookAheadIteration
for processing bind left join results (i.e., result of joining OPTIONAL clauses) Algorithm: execute left bind join using regular bound join query process result iteration similar toBoundJoinVALUESConversionIteration
remember seen set of bindings (using index) and add original bindings to those, i.e.class
Inserts original bindings into the result.class
Inserts original bindings into the result.class
A wrapping iteration that attempts to close the dependentRepositoryConnection
after consumption.class
A specializedCloseableIteration
that consumes part (or the entire input iteration if it fits into the buffer) and keeps data for further processing in memory.class
SpecializedDescribeIteration
for evaluation of DESCRIBE queries in the federation.class
class
An iteration to evaluatedFedXZeroLengthPath
class
Filters iteration according to specified filterExpr and inserts original bindings into filtered results.class
Filters iteration according to specified filterExpr.class
Converts graph results into a binding set iterationclass
Retrieves the original bindings for the particular resultclass
Inserts original bindings into the result.class
Inserts original bindings into the result.class
Inserts original bindings into the result.class
Inserts original bindings into the result.class
A specializedCloseableIteration
that allows repetitive iterations after resetting the cursor usingLazyMutableClosableIteration.resetCursor()
.class
Print the bindings of the inner iteration to stdout, however maintain a copy, which is accessible through this iteration.class
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
Represents an iteration that contains only a single binding set.class
Converts Statement iteration (i.e.class
A wrapping iteration that attempts to close all running scheduledFuture
s for the given query evaluation.Modifier and TypeFieldDescriptionprotected final CloseableIteration
<T> CloseDependentConnectionIteration.inner
protected final CloseableIteration
<BindingSet> LazyMutableClosableIteration.inner
protected final CloseableIteration
<BindingSet> PrintingIteration.inner
protected final CloseableIteration
<BindingSet> QueryResultIteration.inner
protected final CloseableIteration
<? extends BindingSet> StopRemainingExecutionsOnCloseIteration.inner
protected final CloseableIteration
<BindingSet> BindLeftJoinIteration.iter
protected final CloseableIteration
<BindingSet> IndependentJoingroupBindingsIteration.iter
protected final CloseableIteration
<BindingSet> IndependentJoingroupBindingsIteration2.iter
protected final CloseableIteration
<BindingSet> IndependentJoingroupBindingsIteration3.iter
Modifier and TypeMethodDescriptionprotected CloseableIteration
<BindingSet> FederatedDescribeIteration.createNextIteration
(Value subject, Value object) ModifierConstructorDescriptionBindLeftJoinIteration
(CloseableIteration<BindingSet> iter, List<BindingSet> bindings) BoundJoinConversionIteration
(CloseableIteration<BindingSet> iter, List<BindingSet> bindings) BoundJoinVALUESConversionIteration
(CloseableIteration<BindingSet> iter, List<BindingSet> bindings) CloseDependentConnectionIteration
(CloseableIteration<T> inner, RepositoryConnection dependentConn) ConsumingIteration
(CloseableIteration<BindingSet> iter, int max) FederatedDescribeIteration
(CloseableIteration<BindingSet> sourceIter, FederationEvalStrategy strategy, Set<String> describeExprNames, BindingSet parentBindings, QueryInfo queryInfo) FilteringInsertBindingsIteration
(FilterValueExpr filterExpr, BindingSet bindings, CloseableIteration<BindingSet> iter, FederationEvalStrategy strategy) FilteringIteration
(FilterValueExpr filterExpr, CloseableIteration<BindingSet> iter, FederationEvalStrategy strategy) GroupedCheckConversionIteration
(CloseableIteration<BindingSet> iter, List<BindingSet> bindings) IndependentJoingroupBindingsIteration
(CloseableIteration<BindingSet> iter, BindingSet bindings) IndependentJoingroupBindingsIteration2
(CloseableIteration<BindingSet> iter, List<BindingSet> bindings) IndependentJoingroupBindingsIteration3
(CloseableIteration<BindingSet> iter, List<BindingSet> bindings) InsertBindingsIteration
(CloseableIteration<BindingSet> iter, BindingSet bindings) QueryResultIteration
(CloseableIteration<BindingSet> inner, QueryInfo queryInfo) StopRemainingExecutionsOnCloseIteration
(CloseableIteration<? extends BindingSet> inner, QueryInfo queryInfo) -
Uses of CloseableIteration in org.eclipse.rdf4j.federated.evaluation.join
Modifier and TypeClassDescriptionclass
Execution of a regular join as bind join.class
Base class for executing joins as bind joins (i.e., the bindings of a block are injected in the SPARQL query as VALUES clause).class
Bind join implementation for left joins (i.e., OPTIOAL clauses)class
Deprecated, for removal: This API element is subject to removal in a future version.replaced withControlledWorkerBindJoin
lclass
Execute the nested loop join in an asynchronous fashion, i.e.class
Execute the nested loop join in an asynchronous fashion, i.e.class
Operator for a hash join of tuple expressions.class
Base class for any join parallel join executor.class
Execute the nested loop join in a synchronous fashion, using grouped requests, i.e.class
Execute the nested loop join in a synchronous fashion, i.e.Modifier and TypeMethodDescriptionprotected CloseableIteration
<BindingSet> ParallelBindLeftJoinTask.performTaskInternal()
protected CloseableIteration
<BindingSet> ParallelBoundJoinTask.performTaskInternal()
protected CloseableIteration
<BindingSet> ParallelCheckJoinTask.performTaskInternal()
Deprecated, for removal: This API element is subject to removal in a future version.protected CloseableIteration
<BindingSet> ParallelEmptyBindLeftJoinTask.performTaskInternal()
protected CloseableIteration
<BindingSet> ParallelJoinTask.performTaskInternal()
protected CloseableIteration
<BindingSet> ParallelLeftJoinTask.performTaskInternal()
protected CloseableIteration
<BindingSet> ParallelServiceJoinTask.performTaskInternal()
ModifierConstructorDescriptionControlledWorkerBindJoin
(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) ControlledWorkerBindJoinBase
(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) ControlledWorkerBindLeftJoin
(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) ControlledWorkerBoundJoin
(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) Deprecated, for removal: This API element is subject to removal in a future version.ControlledWorkerJoin
(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) ControlledWorkerLeftJoin
(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, LeftJoin join, BindingSet bindings, QueryInfo queryInfo) HashJoin
(FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, QueryEvaluationStep rightPrepared, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo) JoinExecutorBase
(FederationEvalStrategy strategy, CloseableIteration<T> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) SynchronousBoundJoin
(FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) SynchronousJoin
(FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) -
Uses of CloseableIteration in org.eclipse.rdf4j.federated.evaluation.union
Modifier and TypeClassDescriptionclass
Execution of union tasks withControlledWorkerScheduler
.class
Synchronous execution of union tasks, i.e.class
Base class for any parallel union executor.class
Base class for worker unions providing convenience functions to add tasks.Modifier and TypeMethodDescriptionprotected CloseableIteration
<Statement> ParallelGetStatementsTask.performTaskInternal()
protected CloseableIteration
<BindingSet> ParallelPreparedAlgebraUnionTask.performTaskInternal()
protected CloseableIteration
<BindingSet> ParallelPreparedUnionTask.performTaskInternal()
protected CloseableIteration
<BindingSet> ParallelUnionOperatorTask.performTaskInternal()
protected CloseableIteration
<BindingSet> ParallelUnionTask.performTaskInternal()
-
Uses of CloseableIteration in org.eclipse.rdf4j.federated.optimizer
Modifier and TypeMethodDescriptionprotected CloseableIteration
<BindingSet> SourceSelection.ParallelCheckTask.performTaskInternal()
Modifier and TypeMethodDescriptionvoid
SourceSelection.SourceSelectionExecutorWithLatch.addResult
(CloseableIteration<BindingSet> res) -
Uses of CloseableIteration in org.eclipse.rdf4j.query
Modifier and TypeInterfaceDescriptioninterface
A representation of a query result as a sequence ofStatement
objects.interface
QueryResult<T>
Super type of all query result types (TupleQueryResult, GraphQueryResult, etc.).interface
A representation of a variable-binding query result as a sequence ofBindingSet
objects.Modifier and TypeMethodDescriptionstatic Model
QueryResults.asModel
(CloseableIteration<? extends Statement> iteration) Get aModel
containing all elements obtained from the specified query result.static Model
QueryResults.asModel
(CloseableIteration<? extends Statement> iteration, ModelFactory modelFactory) Get aModel
containing all elements obtained from the specified query result. -
Uses of CloseableIteration in org.eclipse.rdf4j.query.algebra
Modifier and TypeMethodDescriptionvoid
BinaryTupleOperator.setAlgorithm
(CloseableIteration<?> iteration) -
Uses of CloseableIteration in org.eclipse.rdf4j.query.algebra.evaluation
Modifier and TypeClassDescriptionstatic class
Utility class that removes code duplication and makes a precompiled QueryEvaluationStep available as an iteration that may be created and used later.Modifier and TypeMethodDescriptionprotected CloseableIteration
<? extends BindingSet> QueryEvaluationStep.DelayedEvaluationIteration.createIteration()
protected abstract CloseableIteration
<? extends BindingSet> AbstractQueryPreparer.evaluate
(TupleExpr tupleExpr, Dataset dataset, BindingSet bindings, boolean includeInferred, int maxExecutionTime) EvaluationStrategy.evaluate
(TupleExpr expr, BindingSet bindings) Evaluates the tuple expression against the supplied triple source with the specified set of variable bindings as input.QueryEvaluationStep.evaluate
(BindingSet bindings) CloseableIteration
<? extends Triple> RDFStarTripleSource.getRdfStarTriples
(Resource subj, IRI pred, Value obj) Gets all Triple nodes that have a specific subject, predicate and/or object.default CloseableIteration
<? extends Statement> TripleSource.getStatements
(StatementOrder order, Resource subj, IRI pred, Value obj, Resource... contexts) Gets all statements that have a specific subject, predicate and/or object.CloseableIteration
<? extends Statement> TripleSource.getStatements
(Resource subj, IRI pred, Value obj, Resource... contexts) Gets all statements that have a specific subject, predicate and/or object.Modifier and TypeMethodDescriptionstatic QueryEvaluationStep
QueryEvaluationStep.wrap
(QueryEvaluationStep qes, Function<CloseableIteration<BindingSet>, CloseableIteration<BindingSet>> wrap) Wrap an QueryEvalationStep: where we apply a function on every evaluation result of the wrapped EvaluationStep.static QueryEvaluationStep
QueryEvaluationStep.wrap
(QueryEvaluationStep qes, Function<CloseableIteration<BindingSet>, CloseableIteration<BindingSet>> wrap) Wrap an QueryEvalationStep: where we apply a function on every evaluation result of the wrapped EvaluationStep. -
Uses of CloseableIteration in org.eclipse.rdf4j.query.algebra.evaluation.federation
Modifier and TypeClassDescriptionclass
Iterator for efficient SERVICE evaluation (vectored).Modifier and TypeMethodDescriptionFederatedService.evaluate
(Service service, CloseableIteration<BindingSet> bindings, String baseUri) Evaluate the provided SPARQL query at this federated service, possibilities for vectored evaluation.FederatedService.select
(Service service, Set<String> projectionVars, BindingSet bindings, String baseUri) Evaluate the provided SPARQL query at this federated service.Modifier and TypeMethodDescriptionFederatedService.evaluate
(Service service, CloseableIteration<BindingSet> bindings, String baseUri) Evaluate the provided SPARQL query at this federated service, possibilities for vectored evaluation.ModifierConstructorDescriptionServiceJoinIterator
(CloseableIteration<BindingSet> leftIter, Service service, BindingSet bindings, EvaluationStrategy strategy) Construct a service join iteration to use vectored evaluation. -
Uses of CloseableIteration in org.eclipse.rdf4j.query.algebra.evaluation.function
Modifier and TypeMethodDescriptionCloseableIteration
<? extends List<? extends Value>> TupleFunction.evaluate
(ValueFactory valueFactory, Value... args) -
Uses of CloseableIteration in org.eclipse.rdf4j.query.algebra.evaluation.impl
Modifier and TypeMethodDescriptionprotected static CloseableIteration
<BindingSet> DefaultEvaluationStrategy.evaluate
(TupleFunction func, List<Var> resultVars, BindingSet bindings, ValueFactory valueFactory, Value... argValues) DefaultEvaluationStrategy.evaluate
(TripleRef ref, BindingSet bindings) evaluates a TripleRef node returning bindingsets from the matched Triple nodes in the dataset (or explore standard reification)DefaultEvaluationStrategy.evaluate
(TupleExpr expr, BindingSet bindings) Deprecated, for removal: This API element is subject to removal in a future version.static CloseableIteration
<BindingSet> ExtendedEvaluationStrategy.evaluate
(TupleFunction func, List<Var> resultVars, BindingSet bindings, ValueFactory valueFactory, Value... argValues) Deprecated, for removal: This API element is subject to removal in a future version.ExtendedEvaluationStrategy.evaluate
(TupleExpr expr, BindingSet bindings) Deprecated, for removal: This API element is subject to removal in a future version.ExtensionQueryEvaluationStep.evaluate
(BindingSet bs) static CloseableIteration
<BindingSet> TupleFunctionEvaluationStrategy.evaluate
(TupleFunction func, List<Var> resultVars, BindingSet bindings, ValueFactory valueFactory, Value... argValues) Deprecated, for removal: This API element is subject to removal in a future version.TupleFunctionEvaluationStrategy.evaluate
(TupleExpr expr, BindingSet bindings) Deprecated, for removal: This API element is subject to removal in a future version.TupleFunctionEvaluationStrategy.evaluate
(TupleFunctionCall expr, BindingSet bindings) Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of CloseableIteration in org.eclipse.rdf4j.query.algebra.evaluation.impl.evaluationsteps
Modifier and TypeMethodDescriptionBindingSetAssignmentQueryEvaluationStep.evaluate
(BindingSet bindings) IntersectionQueryEvaluationStep.evaluate
(BindingSet bs) JoinQueryEvaluationStep.evaluate
(BindingSet bindings) LeftJoinQueryEvaluationStep.evaluate
(BindingSet bindings) MinusQueryEvaluationStep.evaluate
(BindingSet bindings) OrderQueryEvaluationStep.evaluate
(BindingSet bs) ProjectionQueryEvaluationStep.evaluate
(BindingSet bindings) RdfStarQueryEvaluationStep.evaluate
(BindingSet bindings) ReificationRdfStarQueryEvaluationStep.evaluate
(BindingSet bindings) ServiceQueryEvaluationStep.evaluate
(BindingSet bindings) SliceQueryEvaluationStep.OffSetAndLimitQueryEvaluationStep.evaluate
(BindingSet bs) SliceQueryEvaluationStep.OnlyLimitQueryEvaluationStep.evaluate
(BindingSet bs) SliceQueryEvaluationStep.OnlyOffsetQueryEvaluationStep.evaluate
(BindingSet bs) StatementPatternQueryEvaluationStep.evaluate
(BindingSet bindings) UnionQueryEvaluationStep.evaluate
(BindingSet bindings) ZeroLengthPathEvaluationStep.evaluate
(BindingSet bindings) -
Uses of CloseableIteration in org.eclipse.rdf4j.query.algebra.evaluation.iterator
Modifier and TypeClassDescriptionclass
class
class
class
class
Iteration which forms the cross product of a list of materialized input bindings with each result obtained from the inner iteration.class
Iteration that implements a simplified version of Symmetric Concise Bounded Description (omitting reified statements).class
class
class
class
Generic hash join implementation suitable for use by Sail implementations.class
class
Interleaved join iterator.class
class
class
Sorts the input and optionally applies limit and distinct.class
class
An iterator that allows to peek at the next element without consuming it.class
class
Makes aQueryContext
available during iteration.class
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
Modifier and TypeFieldDescriptionprotected final CloseableIteration
<BindingSet> CrossProductIteration.resultIteration
Modifier and TypeMethodDescriptionprotected CloseableIteration
<BindingSet> OrderIterator.createIteration()
protected CloseableIteration
<BindingSet> DescribeIteration.createNextIteration
(Value subject, Value object) static CloseableIteration
<BindingSet> AsyncIteratorBuffer.getInstance
(QueryEvaluationStep iterationPrepared, BindingSet bindings, QueryEvaluationContext context) static CloseableIteration
<BindingSet> AsyncIteratorDirect.getInstance
(QueryEvaluationStep iterationPrepared, BindingSet bindings, QueryEvaluationContext context) static CloseableIteration
<BindingSet> AsyncIteratorReadAhead.getInstance
(QueryEvaluationStep iterationPrepared, BindingSet bindings, QueryEvaluationContext context) static CloseableIteration
<BindingSet> InnerMergeJoinIterator.getInstance
(QueryEvaluationStep leftPrepared, QueryEvaluationStep preparedRight, BindingSet bindings, Comparator<Value> cmp, Function<BindingSet, Value> value, QueryEvaluationContext context) static CloseableIteration
<BindingSet> JoinIterator.getInstance
(QueryEvaluationStep leftPrepared, QueryEvaluationStep preparedRight, BindingSet bindings) static CloseableIteration
<BindingSet> LeftJoinIterator.getInstance
(QueryEvaluationStep left, QueryEvaluationStep prepareRightArg, QueryValueEvaluationStep joinCondition, BindingSet bindings, Set<String> scopeBindingNamse) protected CloseableIteration
<BindingSet> SPARQLMinusIteration.getRightArg()
Modifier and TypeMethodDescriptionprotected Collection
<BindingSet> HashJoinIteration.makeIterationCache
(CloseableIteration<BindingSet> iter) Utility methods to make it easier to inserted custom store dependent listprotected Set
<BindingSet> SPARQLMinusIteration.makeSet
(CloseableIteration<BindingSet> rightArg) ModifierConstructorDescriptionAsyncIteratorBuffer
(CloseableIteration<BindingSet> iteration) AsyncIteratorDirect
(CloseableIteration<BindingSet> iteration) AsyncIteratorReadAhead
(CloseableIteration<BindingSet> iteration) CrossProductIteration
(CloseableIteration<BindingSet> resultIteration, List<BindingSet> inputBindings) DescribeIteration
(CloseableIteration<BindingSet> sourceIter, EvaluationStrategy strategy, Set<String> describeExprNames, BindingSet parentBindings) ExtensionIterator
(CloseableIteration<BindingSet> iter, Consumer<MutableBindingSet> setter, QueryEvaluationContext context) ExtensionIterator
(Extension extension, CloseableIteration<BindingSet> iter, EvaluationStrategy strategy, QueryEvaluationContext context) FilterIterator
(Filter filter, CloseableIteration<BindingSet> iter, QueryValueEvaluationStep condition, EvaluationStrategy strategy) HashJoinIteration
(CloseableIteration<BindingSet> leftIter, Set<String> leftBindingNames, CloseableIteration<BindingSet> rightIter, Set<String> rightBindingNames, boolean leftJoin) Deprecated, for removal: This API element is subject to removal in a future version.LeftJoinIterator
(CloseableIteration<BindingSet> leftIter, QueryEvaluationStep prepareRightArg, QueryValueEvaluationStep joinCondition, Set<String> scopeBindingNamse) MultiProjectionIterator
(MultiProjection multiProjection, CloseableIteration<BindingSet> iter, BindingSet bindings) OrderIterator
(CloseableIteration<BindingSet> iter, Comparator<BindingSet> comparator) OrderIterator
(CloseableIteration<BindingSet> iter, Comparator<BindingSet> comparator, long limit, boolean distinct) OrderIterator
(CloseableIteration<BindingSet> iter, Comparator<BindingSet> comparator, long limit, boolean distinct, long iterationSyncThreshold) PeekMarkIterator
(CloseableIteration<E> iterator) ProjectionIterator
(Projection projection, CloseableIteration<BindingSet> iter, BindingSet parentBindings, QueryEvaluationContext context) QueryContextIteration
(CloseableIteration<? extends BindingSet> iter, QueryContext queryContext) SPARQLMinusIteration
(CloseableIteration<BindingSet> leftArg, CloseableIteration<BindingSet> rightArg) Creates a new MinusIteration that returns the results of the left argument minus the results of the right argument. -
Uses of CloseableIteration in org.eclipse.rdf4j.query.algebra.evaluation.util
Modifier and TypeMethodDescriptionstatic CloseableIteration
<Literal> TripleSources.getObjectLiterals
(Resource subject, IRI predicate, TripleSource store) Deprecated, for removal: This API element is subject to removal in a future version.static CloseableIteration
<Resource> TripleSources.getObjectResources
(Resource subject, IRI predicate, TripleSource store) Deprecated, for removal: This API element is subject to removal in a future version.static CloseableIteration
<IRI> TripleSources.getObjectURIs
(Resource subject, IRI predicate, TripleSource store) Deprecated, for removal: This API element is subject to removal in a future version.static CloseableIteration
<IRI> TripleSources.getSubjectURIs
(IRI predicate, Value object, TripleSource store) Deprecated, for removal: This API element is subject to removal in a future version.static CloseableIteration
<Value> TripleSources.list
(Resource subj, TripleSource store) Deprecated, for removal: This API element is subject to removal in a future version.static CloseableIteration
<Resource> TripleSources.listResources
(Resource subj, TripleSource store) Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of CloseableIteration in org.eclipse.rdf4j.query.impl
Modifier and TypeClassDescriptionclass
Provides concurrent access to statements as they are being parsed when instances of this class are run as Threads.class
An iterating implementation of theGraphQueryResult
interface.class
An iterating implementation of theTupleQueryResult
interface.class
An implementation of theTupleQueryResult
interface that stores the complete query result in memory.class
QueueCursor<E>
Makes working with a queue easier by adding the methodsQueueIteration.done()
andQueueIteration.toss(Exception)
and automatically converting the exception into a QueryEvaluationException with an appropriate stack trace.Modifier and TypeMethodDescriptionprotected CloseableIteration
<? extends BindingSet> AbstractParserQuery.enforceMaxQueryTime
(CloseableIteration<? extends BindingSet> bindingsIter) Modifier and TypeMethodDescriptionprotected CloseableIteration
<? extends BindingSet> AbstractParserQuery.enforceMaxQueryTime
(CloseableIteration<? extends BindingSet> bindingsIter) ModifierConstructorDescriptionIteratingGraphQueryResult
(Map<String, String> namespaces, CloseableIteration<? extends Statement> statementIter) IteratingTupleQueryResult
(List<String> bindingNames, CloseableIteration<? extends BindingSet> bindingSetIter) Creates a query result object with the supplied binding names.MutableTupleQueryResult
(Collection<String> bindingNames, CloseableIteration<? extends BindingSet> bindingSetIter) -
Uses of CloseableIteration in org.eclipse.rdf4j.query.parser.impl
Modifier and TypeMethodDescriptionprotected CloseableIteration
<? extends BindingSet> AbstractParserQuery.enforceMaxQueryTime
(CloseableIteration<? extends BindingSet> bindingsIter) Modifier and TypeMethodDescriptionprotected CloseableIteration
<? extends BindingSet> AbstractParserQuery.enforceMaxQueryTime
(CloseableIteration<? extends BindingSet> bindingsIter) -
Uses of CloseableIteration in org.eclipse.rdf4j.query.resultio.helpers
Modifier and TypeClassDescriptionclass
Provides concurrent access to tuple results as they are being parsed. -
Uses of CloseableIteration in org.eclipse.rdf4j.repository
Modifier and TypeClassDescriptionclass
Modifier and TypeMethodDescriptionvoid
RepositoryConnection.add
(CloseableIteration<? extends Statement> statements, Resource... contexts) Adds the supplied statements to this repository, optionally to one or more named contexts.void
RepositoryConnection.remove
(CloseableIteration<? extends Statement> statements, Resource... contexts) Removes the supplied statements from a specific context in this repository, ignoring any context information carried by the statements themselves. -
Uses of CloseableIteration in org.eclipse.rdf4j.repository.base
Modifier and TypeMethodDescriptionvoid
AbstractRepositoryConnection.add
(CloseableIteration<? extends Statement> statements, Resource... contexts) void
RepositoryConnectionWrapper.add
(CloseableIteration<? extends Statement> statementIter, Resource... contexts) void
AbstractRepositoryConnection.remove
(CloseableIteration<? extends Statement> statements, Resource... contexts) void
RepositoryConnectionWrapper.remove
(CloseableIteration<? extends Statement> statementIter, Resource... contexts) -
Uses of CloseableIteration in org.eclipse.rdf4j.repository.contextaware
Modifier and TypeMethodDescriptionvoid
ContextAwareConnection.add
(CloseableIteration<? extends Statement> statementIter, Resource... contexts) void
ContextAwareConnection.remove
(CloseableIteration<? extends Statement> statementIter, Resource... contexts) Removes the supplied statements from a specific context in this repository, ignoring any context information carried by the statements themselves. -
Uses of CloseableIteration in org.eclipse.rdf4j.repository.evaluation
Modifier and TypeMethodDescriptionCloseableIteration
<? extends Statement> RepositoryTripleSource.getStatements
(Resource subj, IRI pred, Value obj, Resource... contexts) -
Uses of CloseableIteration in org.eclipse.rdf4j.repository.sail
Modifier and TypeMethodDescriptionprotected <E> RepositoryResult
<E> SailRepositoryConnection.createRepositoryResult
(CloseableIteration<? extends E> sailIter) Wraps a CloseableIteration coming from a Sail in a RepositoryResult object, applying the required conversions -
Uses of CloseableIteration in org.eclipse.rdf4j.repository.sparql.federation
Modifier and TypeClassDescriptionclass
An iteration to access a materializedCollection
of BindingSets.class
Base class for any join parallel join executor.class
Inserts original bindings into the result, uses ?__rowIdx to resolve original bindings.class
Iteration which forms the cross product of a list of materialized input bindings with each result obtained from the inner iteration.Modifier and TypeFieldDescriptionprotected final CloseableIteration
<T> JoinExecutorBase.leftIter
protected final CloseableIteration
<BindingSet> SPARQLCrossProductIteration.resultIteration
protected CloseableIteration
<T> JoinExecutorBase.rightIter
Modifier and TypeFieldDescriptionprotected final QueueCursor
<CloseableIteration<T>> JoinExecutorBase.rightQueue
Modifier and TypeMethodDescriptionRepositoryFederatedService.evaluate
(Service service, CloseableIteration<BindingSet> bindings, String baseUri) protected CloseableIteration
<BindingSet> RepositoryFederatedService.evaluateInternal
(Service service, CloseableIteration<BindingSet> bindings, String baseUri) Evaluate the SPARQL query that can be constructed from the SERVICE node at the initializedRepository
of thisFederatedService
.RepositoryFederatedService.select
(Service service, Set<String> projectionVars, BindingSet bindings, String baseUri) Evaluate the provided sparqlQueryString at the initializedRepository
of thisFederatedService
.Modifier and TypeMethodDescriptionvoid
JoinExecutorBase.addResult
(CloseableIteration<T> res) RepositoryFederatedService.evaluate
(Service service, CloseableIteration<BindingSet> bindings, String baseUri) protected CloseableIteration
<BindingSet> RepositoryFederatedService.evaluateInternal
(Service service, CloseableIteration<BindingSet> bindings, String baseUri) Evaluate the SPARQL query that can be constructed from the SERVICE node at the initializedRepository
of thisFederatedService
.ModifierConstructorDescriptionprotected
JoinExecutorBase
(CloseableIteration<T> leftIter, TupleExpr rightArg, BindingSet bindings) ServiceJoinConversionIteration
(CloseableIteration<BindingSet> iter, List<BindingSet> bindings) SPARQLCrossProductIteration
(CloseableIteration<BindingSet> resultIteration, List<BindingSet> inputBindings) -
Uses of CloseableIteration in org.eclipse.rdf4j.repository.sparql.query
Modifier and TypeClassDescriptionclass
Adds more bindings to each of the results.ModifierConstructorDescriptionInsertBindingSetCursor
(CloseableIteration<BindingSet> delegate, BindingSet bindings) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail
Modifier and TypeMethodDescriptionCloseableIteration
<? extends BindingSet> 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> SailConnection.getContextIDs()
Returns the set of all unique context identifiers that are used to store statements.CloseableIteration
<? extends Namespace> SailConnection.getNamespaces()
Gets the namespaces relevant to the data contained in this Sail object.default CloseableIteration
<? extends Statement> SailConnection.getStatements
(StatementOrder statementOrder, 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.CloseableIteration
<? extends Statement> 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.ModifierConstructorDescriptionTripleSourceIterationWrapper
(CloseableIteration<? extends T> delegate) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.base
Modifier and TypeClassDescriptionclass
An Iteration that takes two source.Modifier and TypeMethodDescriptionprotected CloseableIteration
<? extends BindingSet> SailSourceConnection.evaluateInternal
(TupleExpr tupleExpr, Dataset dataset, BindingSet bindings, boolean includeInferred) CloseableIteration
<? extends Resource> SailDataset.getContextIDs()
Returns the set of all unique context identifiers that are used to store statements.protected CloseableIteration
<? extends Resource> SailSourceConnection.getContextIDsInternal()
CloseableIteration
<? extends Namespace> SailDataset.getNamespaces()
Gets the namespaces relevant to the data contained in this object.protected CloseableIteration
<? extends Namespace> SailSourceConnection.getNamespacesInternal()
CloseableIteration
<? extends Triple> SailDatasetTripleSource.getRdfStarTriples
(Resource subj, IRI pred, Value obj) default CloseableIteration
<? extends Statement> SailDataset.getStatements
(StatementOrder statementOrder, Resource subj, IRI pred, Value obj, Resource... contexts) Gets all statements that have a specific subject, predicate and/or object.CloseableIteration
<? extends Statement> SailDataset.getStatements
(Resource subj, IRI pred, Value obj, Resource... contexts) Gets all statements that have a specific subject, predicate and/or object.CloseableIteration
<? extends Statement> SailDatasetTripleSource.getStatements
(StatementOrder order, Resource subj, IRI pred, Value obj, Resource... contexts) CloseableIteration
<? extends Statement> SailDatasetTripleSource.getStatements
(Resource subj, IRI pred, Value obj, Resource... contexts) protected CloseableIteration
<? extends Statement> SailSourceConnection.getStatementsInternal
(StatementOrder order, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) protected CloseableIteration
<? extends Statement> SailSourceConnection.getStatementsInternal
(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) default CloseableIteration
<? extends Triple> SailDataset.getTriples
(Resource subj, IRI pred, Value obj) Gets all RDF-star triples that have a specific subject, predicate and/or object. -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.evaluation
Modifier and TypeMethodDescriptionCloseableIteration
<? extends Statement> SailTripleSource.getStatements
(StatementOrder order, Resource subj, IRI pred, Value obj, Resource... contexts) CloseableIteration
<? extends Statement> SailTripleSource.getStatements
(Resource subj, IRI pred, Value obj, Resource... contexts) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.extensiblestore
Modifier and TypeClassDescriptionclass
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...class
SortedIteration<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 TypeMethodDescriptiondefault CloseableIteration
<? extends ExtensibleStatement> DataStructureInterface.getStatements
(StatementOrder statementOrder, Resource subject, IRI predicate, Value object, boolean inferred, Resource... contexts) CloseableIteration
<? extends ExtensibleStatement> DataStructureInterface.getStatements
(Resource subject, IRI predicate, Value object, boolean inferred, Resource... contexts) CloseableIteration
<? extends ExtensibleStatement> EagerReadCache.getStatements
(Resource subject, IRI predicate, Value object, boolean inferred, Resource... context) CloseableIteration
<? extends ExtensibleStatement> LazyReadCache.getStatements
(Resource subject, IRI predicate, Value object, boolean inferred, Resource... context) ModifierConstructorDescriptionFilteringIteration
(CloseableIteration<E> wrappedIteration, Resource subject, IRI predicate, Value object, boolean inferred, Resource... context) SortedIteration
(CloseableIteration<E> wrappedIteration, StatementOrder statementOrder) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.extensiblestore.evaluationstatistics
Modifier and TypeMethodDescriptionCloseableIteration
<? extends ExtensibleStatement> EvaluationStatisticsWrapper.getStatements
(StatementOrder statementOrder, Resource subject, IRI predicate, Value object, boolean inferred, Resource... contexts) CloseableIteration
<? extends ExtensibleStatement> EvaluationStatisticsWrapper.getStatements
(Resource subject, IRI predicate, Value object, boolean inferred, Resource... context) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.helpers
Modifier and TypeMethodDescriptionfinal CloseableIteration
<? extends BindingSet> AbstractSailConnection.evaluate
(TupleExpr tupleExpr, Dataset dataset, BindingSet bindings, boolean includeInferred) CloseableIteration
<? extends BindingSet> SailConnectionWrapper.evaluate
(TupleExpr tupleExpr, Dataset dataset, BindingSet bindings, boolean includeInferred) protected abstract CloseableIteration
<? extends BindingSet> AbstractSailConnection.evaluateInternal
(TupleExpr tupleExpr, Dataset dataset, BindingSet bindings, boolean includeInferred) final CloseableIteration
<? extends Resource> AbstractSailConnection.getContextIDs()
CloseableIteration
<? extends Resource> SailConnectionWrapper.getContextIDs()
protected abstract CloseableIteration
<? extends Resource> AbstractSailConnection.getContextIDsInternal()
final CloseableIteration
<? extends Namespace> AbstractSailConnection.getNamespaces()
CloseableIteration
<? extends Namespace> SailConnectionWrapper.getNamespaces()
protected abstract CloseableIteration
<? extends Namespace> AbstractSailConnection.getNamespacesInternal()
final CloseableIteration
<? extends Statement> AbstractSailConnection.getStatements
(StatementOrder order, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) final CloseableIteration
<? extends Statement> AbstractSailConnection.getStatements
(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) CloseableIteration
<? extends Statement> SailConnectionWrapper.getStatements
(StatementOrder statementOrder, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) CloseableIteration
<? extends Statement> SailConnectionWrapper.getStatements
(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) protected CloseableIteration
<? extends Statement> AbstractSailConnection.getStatementsInternal
(StatementOrder order, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) protected abstract CloseableIteration
<? extends Statement> AbstractSailConnection.getStatementsInternal
(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) protected <T,
E extends Exception>
CloseableIteration<T> AbstractSailConnection.registerIteration
(CloseableIteration<T> iter) Registers an iteration as active by wrapping it in aSailBaseIteration
object and adding it to the list of active iterations.Modifier and TypeMethodDescriptionprotected <T,
E extends Exception>
CloseableIteration<T> AbstractSailConnection.registerIteration
(CloseableIteration<T> iter) Registers an iteration as active by wrapping it in aSailBaseIteration
object and adding it to the list of active iterations. -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.inferencer
Modifier and TypeMethodDescriptionCloseableIteration
<? extends BindingSet> InferencerConnectionWrapper.evaluate
(TupleExpr tupleExpr, Dataset dataset, BindingSet bindings, boolean includeInferred) CallsInferencerConnectionWrapper.flushUpdates()
before forwarding the call to the wrapped connection.CloseableIteration
<? extends Resource> InferencerConnectionWrapper.getContextIDs()
CallsInferencerConnectionWrapper.flushUpdates()
before forwarding the call to the wrapped connection.CloseableIteration
<? extends Statement> InferencerConnectionWrapper.getStatements
(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) CallsInferencerConnectionWrapper.flushUpdates()
before forwarding the call to the wrapped connection. -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.lmdb
Modifier and TypeMethodDescriptionprotected CloseableIteration
<? extends BindingSet> LmdbStoreConnection.evaluateInternal
(TupleExpr tupleExpr, Dataset dataset, BindingSet bindings, boolean includeInferred) protected CloseableIteration
<? extends Statement> LmdbStoreConnection.getStatementsInternal
(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.lucene
Modifier and TypeMethodDescriptionCloseableIteration
<? extends BindingSet> LuceneSailConnection.evaluate
(TupleExpr tupleExpr, Dataset dataset, BindingSet bindings, boolean includeInferred) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.memory.model
Modifier and TypeClassDescriptionclass
A StatementIterator that can iterate over a list of Statement objects.class
MemTripleIterator<X extends Exception>
An Iteration that can iterate over a list ofTriple
objects.Modifier and TypeMethodDescriptionstatic CloseableIteration
<MemStatement> MemStatementIterator.cacheAwareInstance
(MemStatementList smallestList, MemResource subj, MemIRI pred, MemValue obj, Boolean explicit, int snapshot, MemResource[] memContexts, MemStatementIteratorCache iteratorCache) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.shacl
Modifier and TypeMethodDescriptionCloseableIteration
<? extends Statement> ShaclSailConnection.getStatements
(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.shacl.ast.planNodes
Modifier and TypeMethodDescriptionInnerJoin.internalIterator()
CloseableIteration
<? extends ValidationTuple> AllTargetsPlanNode.iterator()
CloseableIteration
<? extends ValidationTuple> BindSelect.iterator()
CloseableIteration
<? extends ValidationTuple> BufferedPlanNode.iterator()
CloseableIteration
<? extends ValidationTuple> BufferedSplitter.BufferedSplitterPlaneNode.iterator()
CloseableIteration
<? extends ValidationTuple> BulkedExternalInnerJoin.iterator()
CloseableIteration
<? extends ValidationTuple> BulkedExternalLeftOuterJoin.iterator()
CloseableIteration
<? extends ValidationTuple> DebugPlanNode.iterator()
CloseableIteration
<? extends ValidationTuple> EmptyNode.iterator()
CloseableIteration
<? extends ValidationTuple> EqualsJoin.iterator()
CloseableIteration
<? extends ValidationTuple> EqualsJoinValue.iterator()
CloseableIteration
<? extends ValidationTuple> FilterByPredicate.iterator()
CloseableIteration
<? extends ValidationTuple> FilterByPredicateObject.iterator()
CloseableIteration
<? extends ValidationTuple> FilterPlanNode.iterator()
CloseableIteration
<? extends ValidationTuple> GroupByCountFilter.iterator()
CloseableIteration
<? extends ValidationTuple> GroupByFilter.iterator()
CloseableIteration
<? extends ValidationTuple> InnerJoin.iterator()
CloseableIteration
<? extends ValidationTuple> LeftOuterJoin.iterator()
CloseableIteration
<? extends ValidationTuple> NonUniqueTargetLang.iterator()
CloseableIteration
<? extends ValidationTuple> NotValuesIn.iterator()
CloseableIteration
<? extends ValidationTuple> PlanNode.iterator()
CloseableIteration
<? extends ValidationTuple> ReduceTargets.iterator()
CloseableIteration
<? extends ValidationTuple> Select.iterator()
CloseableIteration
<? extends ValidationTuple> SetFilterNode.iterator()
CloseableIteration
<? extends ValidationTuple> ShiftToNodeShape.iterator()
CloseableIteration
<? extends ValidationTuple> ShiftToPropertyShape.iterator()
CloseableIteration
<? extends ValidationTuple> SingleCloseablePlanNode.iterator()
CloseableIteration
<? extends ValidationTuple> Sort.iterator()
CloseableIteration
<? extends ValidationTuple> SparqlConstraintSelect.iterator()
CloseableIteration
<? extends ValidationTuple> TargetChainPopper.iterator()
CloseableIteration
<? extends ValidationTuple> TrimToTarget.iterator()
CloseableIteration
<? extends ValidationTuple> TupleMapper.iterator()
CloseableIteration
<? extends ValidationTuple> UnBufferedPlanNode.iterator()
CloseableIteration
<? extends ValidationTuple> UnionNode.iterator()
CloseableIteration
<? extends ValidationTuple> Unique.iterator()
CloseableIteration
<? extends ValidationTuple> UnorderedSelect.iterator()
CloseableIteration
<? extends ValidationTuple> ValidationReportNode.iterator()
CloseableIteration
<? extends ValidationTuple> ValuesBackedNode.iterator()
-
Uses of CloseableIteration in org.eclipse.rdf4j.sail.shacl.ast.targets
Modifier and TypeMethodDescriptionCloseableIteration
<? extends ValidationTuple> TargetChainRetriever.iterator()
-
Uses of CloseableIteration in org.eclipse.rdf4j.sail.shacl.results.lazy
ModifierConstructorDescriptionValidationResultIterator
(CloseableIteration<? extends ValidationTuple> tupleIterator, long limit) -
Uses of CloseableIteration in org.eclipse.rdf4j.sail.shacl.wrapper.data
Modifier and TypeMethodDescriptionCloseableIteration
<? extends Statement> VerySimpleRdfsBackwardsChainingConnection.getStatements
(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts) -
Uses of CloseableIteration in org.eclipse.rdf4j.spin.function
Modifier and TypeMethodDescriptionCloseableIteration
<? extends List<? extends Value>> ConstructTupleFunction.evaluate
(ValueFactory valueFactory, Value... args) CloseableIteration
<? extends List<? extends Value>> SelectTupleFunction.evaluate
(ValueFactory valueFactory, Value... args) CloseableIteration
<? extends List<? extends Value>> SpinTupleFunction.evaluate
(ValueFactory valueFactory, Value... args) -
Uses of CloseableIteration in org.eclipse.rdf4j.spin.function.apf
Modifier and TypeMethodDescriptionCloseableIteration
<? extends List<? extends Value>> ConcatTupleFunction.evaluate
(ValueFactory valueFactory, Value... args) -
Uses of CloseableIteration in org.eclipse.rdf4j.spin.function.list
Modifier and TypeMethodDescriptionCloseableIteration
<? extends List<? extends Value>> Index.evaluate
(ValueFactory valueFactory, Value... args) CloseableIteration
<? extends List<? extends Value>> Length.evaluate
(ValueFactory valueFactory, Value... args) CloseableIteration
<? extends List<? extends Value>> Member.evaluate
(ValueFactory valueFactory, Value... args) -
Uses of CloseableIteration in org.eclipse.rdf4j.spin.function.spif
Modifier and TypeMethodDescriptionCloseableIteration
<? extends List<? extends Value>> For.evaluate
(ValueFactory valueFactory, Value... args) CloseableIteration
<? extends List<? extends Value>> ForEach.evaluate
(ValueFactory valueFactory, Value... args) CloseableIteration
<? extends List<? extends Value>> Split.evaluate
(ValueFactory valueFactory, Value... args) -
Uses of CloseableIteration in org.eclipse.rdf4j.spring.operationlog
Modifier and TypeMethodDescriptionvoid
LoggingRepositoryConnection.add
(CloseableIteration<? extends Statement> statementIter, Resource... contexts) void
LoggingRepositoryConnection.remove
(CloseableIteration<? extends Statement> statementIter, Resource... contexts) -
Uses of CloseableIteration in org.eclipse.rdf4j.spring.resultcache
Modifier and TypeClassDescriptionclass
class
class
Wrapper for a TupleQueryResult, allowing the result to be replayed.class
Wrapper for a TupleQueryResult, allowing the result to be replayed.Modifier and TypeMethodDescriptionvoid
CachingRepositoryConnection.add
(CloseableIteration<? extends Statement> statementIter, Resource... contexts) void
CachingRepositoryConnection.remove
(CloseableIteration<? extends Statement> statementIter, Resource... contexts) -
Uses of CloseableIteration in org.eclipse.rdf4j.spring.tx
Modifier and TypeMethodDescriptionvoid
TransactionalRepositoryConnection.add
(CloseableIteration<? extends Statement> statementIter, Resource... contexts) void
TransactionalRepositoryConnection.remove
(CloseableIteration<? extends Statement> statementIter, Resource... contexts)