public class ServiceFallbackIteration extends JoinExecutorBase<BindingSet>
Modifier and Type | Field and Description |
---|---|
protected Collection<BindingSet> |
bindings |
protected FederatedService |
federatedService |
protected String |
preparedQuery |
protected Service |
service |
closed, evaluationThread, finished, leftIter, NEXT_JOIN_ID, rightArg, rightIter, rightQueue
Constructor and Description |
---|
ServiceFallbackIteration(Service service,
String preparedQuery,
Collection<BindingSet> bindings,
FederatedService federatedService) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleBindings()
Implementations must implement this method to handle bindings.
|
addResult, done, getNextElement, handleClose, isFinished, run, toss
hasNext, next, remove
close, isClosed
protected final Service service
protected final String preparedQuery
protected final FederatedService federatedService
protected final Collection<BindingSet> bindings
public ServiceFallbackIteration(Service service, String preparedQuery, Collection<BindingSet> bindings, FederatedService federatedService) throws QueryEvaluationException
QueryEvaluationException
protected void handleBindings() throws Exception
JoinExecutorBase
while (!closed && leftIter.hasNext()) {
// your code
}
and add results to rightQueue. Note that addResult() is
implemented synchronized and thus thread safe. In case you can guarantee
sequential access, it is also possible to directly access rightQueuehandleBindings
in class JoinExecutorBase<BindingSet>
Exception
Copyright © 2001-2013 Aduna. All Rights Reserved.