Class SynchronousWorkerUnion<T>

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

public class SynchronousWorkerUnion<T> extends WorkerUnionBase<T>
Synchronous execution of union tasks, i.e. one after the other. The union result is contained in this iteration. Note that the union operation is to be executed with the ParallelExecutorBase.run() method
Author:
Andreas Schwarte
  • Constructor Details

    • SynchronousWorkerUnion

      public SynchronousWorkerUnion(QueryInfo queryInfo)
  • Method Details

    • union

      protected void union() throws Exception
      Description copied from class: UnionExecutorBase
      Note: this method must block until the union is executed completely. Otherwise the result queue is marked as committed while this isn't the case. The blocking behavior in general is no problem: If you need concurrent access to the result (i.e. pipelining) just run the union in a separate thread. Access to the result iteration is synchronized.
      Specified by:
      union in class UnionExecutorBase<T>
      Throws:
      Exception