Class FedXQueueCursor<T>
java.lang.Object
org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<E>
org.eclipse.rdf4j.common.iteration.LookAheadIteration<E>
org.eclipse.rdf4j.common.iteration.QueueIteration<E,QueryEvaluationException>
org.eclipse.rdf4j.query.impl.QueueCursor<CloseableIteration<T>>
org.eclipse.rdf4j.federated.evaluation.concurrent.FedXQueueCursor<T>
- Type Parameters:
T-
- All Implemented Interfaces:
AutoCloseable,Iterator<CloseableIteration<T>>,CloseableIteration<CloseableIteration<T>>
Specialized variants of
QueueCursor which avoids converting any exception if it is already of
typeQueryEvaluationException.- Author:
- Andreas Schwarte
-
Method Summary
Modifier and TypeMethodDescriptionprotected QueryEvaluationExceptionConverts an exception from the underlying iteration to an exception of type X.static <T> FedXQueueCursor<T>create(int capacity) static <T> FedXQueueCursor<T>create(int capacity, WeakReference<?> callerReference) voidCalled byAbstractCloseableIteration.close()when it is called for the first time.Methods inherited from class org.eclipse.rdf4j.common.iteration.QueueIteration
checkException, done, getNextElement, put, tossMethods inherited from class org.eclipse.rdf4j.common.iteration.LookAheadIteration
hasNext, next, removeMethods inherited from class org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration
close, isClosedMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.eclipse.rdf4j.common.iteration.CloseableIteration
streamMethods inherited from interface java.util.Iterator
forEachRemaining
-
Method Details
-
create
-
create
-
convert
Description copied from class:QueueIterationConverts an exception from the underlying iteration to an exception of type X.- Overrides:
convertin classQueueCursor<CloseableIteration<T>>
-
handleClose
Description copied from class:AbstractCloseableIterationCalled byAbstractCloseableIteration.close()when it is called for the first time. This method is only called once on each iteration. By default, this method does nothing.- Overrides:
handleClosein classQueueIteration<CloseableIteration<T>,QueryEvaluationException> - Throws:
QueryEvaluationException
-