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>>
public class FedXQueueCursor<T> extends QueueCursor<CloseableIteration<T>>
Specialized variants ofQueueCursorwhich avoids converting any exception if it is already of typeQueryEvaluationException.- Author:
- Andreas Schwarte
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected QueryEvaluationExceptionconvert(Exception e)Converts 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)voidhandleClose()Called byAbstractCloseableIteration.close()when it is called for the first time.-
Methods inherited from class org.eclipse.rdf4j.common.iteration.QueueIteration
checkException, done, getNextElement, put, toss
-
Methods inherited from class org.eclipse.rdf4j.common.iteration.LookAheadIteration
hasNext, next, remove
-
Methods inherited from class org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration
close, isClosed
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.eclipse.rdf4j.common.iteration.CloseableIteration
stream
-
Methods inherited from interface java.util.Iterator
forEachRemaining
-
-
-
-
Method Detail
-
create
public static <T> FedXQueueCursor<T> create(int capacity, WeakReference<?> callerReference)
-
create
public static <T> FedXQueueCursor<T> create(int capacity)
-
convert
protected QueryEvaluationException convert(Exception e)
Description copied from class:QueueIterationConverts an exception from the underlying iteration to an exception of type X.- Overrides:
convertin classQueueCursor<CloseableIteration<T>>
-
handleClose
public void handleClose() throws QueryEvaluationExceptionDescription 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
-
-