public class ServiceJoinIterator extends JoinExecutorBase<BindingSet>
| Modifier and Type | Field and Description |
|---|---|
protected Service |
service |
protected EvaluationStrategy |
strategy |
bindings, closed, finished, leftIter, NEXT_JOIN_ID, rightArg, rightIter, rightQueue| Constructor and Description |
|---|
ServiceJoinIterator(CloseableIteration<BindingSet,QueryEvaluationException> leftIter,
Service service,
BindingSet bindings,
EvaluationStrategy strategy)
Construct a service join iteration to use vectored evaluation.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
handleBindings()
Implementations must implement this method to handle bindings.
|
addResult, done, getNextElement, handleClose, isFinished, run, tosshasNext, next, removeclose, isClosedprotected Service service
protected EvaluationStrategy strategy
public ServiceJoinIterator(CloseableIteration<BindingSet,QueryEvaluationException> leftIter, Service service, BindingSet bindings, EvaluationStrategy strategy) throws QueryEvaluationException
leftIter - service - bindings - strategy - QueryEvaluationExceptionprotected 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>ExceptionCopyright © 2015-2021 Eclipse Foundation. All Rights Reserved.