Class RepositoryFederatedService.BatchingServiceIteration

All Implemented Interfaces:
AutoCloseable, CloseableIteration<BindingSet,QueryEvaluationException>, Iteration<BindingSet,QueryEvaluationException>
Enclosing class:
RepositoryFederatedService

private class RepositoryFederatedService.BatchingServiceIteration extends JoinExecutorBase<BindingSet>
A convenience iteration for SERVICE expression which evaluates intermediate results in batches and manages all results. Uses JoinExecutorBase facilities to guarantee correct access to the final results
  • Field Details

    • blockSize

      private final int blockSize
    • service

      private final Service service
  • Constructor Details

  • Method Details

    • handleBindings

      protected void handleBindings() throws Exception
      Description copied from class: JoinExecutorBase
      Implementations must implement this method to handle bindings. Use the following as a template while (!closed invalid input: '&'invalid input: '&' 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 rightQueue
      Specified by:
      handleBindings in class JoinExecutorBase<BindingSet>
      Throws:
      Exception