Class ControlledWorkerBoundJoin

All Implemented Interfaces:
AutoCloseable, Runnable, CloseableIteration<BindingSet,QueryEvaluationException>, Iteration<BindingSet,QueryEvaluationException>, ParallelExecutor<BindingSet>

public class ControlledWorkerBoundJoin extends ControlledWorkerJoin
Execute the nested loop join in an asynchronous fashion, using grouped requests, i.e. group bindings into one SPARQL request using the UNION operator. The number of concurrent threads is controlled by a ControlledWorkerScheduler which works according to the FIFO principle and uses worker threads. This join cursor blocks until all scheduled tasks are finished, however the result iteration can be accessed from different threads to allow for pipelining.
Author:
Andreas Schwarte