Class UnionExecutorBase<T>

java.lang.Object
All Implemented Interfaces:
AutoCloseable, Runnable, Iterator<T>, CloseableIteration<T>, ParallelExecutor<T>
Direct Known Subclasses:
WorkerUnionBase

public abstract class UnionExecutorBase<T> extends ParallelExecutorBase<T>
Base class for any parallel union executor. Note that this class extends LookAheadIteration and thus any implementation of this class is applicable for pipelining when used in a different thread (access to shared variables is synchronized).
Author:
Andreas Schwarte