Package org.eclipse.rdf4j.federated.evaluation.concurrent

Class FedXQueueCursor<T>

java.lang.Object

org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<CloseableIteration<T>>

org.eclipse.rdf4j.common.iteration.LookAheadIteration<CloseableIteration<T>>

org.eclipse.rdf4j.common.iteration.QueueIteration<CloseableIteration<T>,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 of QueueCursor which avoids converting any exception if it is already of typeQueryEvaluationException.

Author:

Andreas Schwarte

Method Summary

Modifier and Type	Method	Description
protected QueryEvaluationException	convert(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)
void	handleClose()	Called by AbstractCloseableIteration.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 Details

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: QueueIteration

Converts an exception from the underlying iteration to an exception of type X.

Overrides:

convert in class QueueCursor<CloseableIteration<T>>

handleClose

public void handleClose()
                 throws QueryEvaluationException

Description copied from class: AbstractCloseableIteration

Called by AbstractCloseableIteration.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:

handleClose in class QueueIteration<CloseableIteration<T>,QueryEvaluationException>

Throws:

QueryEvaluationException