Interface ParallelTask<T>

All Known Implementing Classes:
ParallelBindLeftJoinTask, ParallelBoundJoinTask, ParallelCheckJoinTask, ParallelEmptyBindLeftJoinTask, ParallelGetStatementsTask, ParallelJoinTask, ParallelLeftJoinTask, ParallelPreparedAlgebraUnionTask, ParallelPreparedUnionTask, ParallelServiceJoinTask, ParallelTaskBase, ParallelUnionOperatorTask, ParallelUnionTask, SourceSelection.ParallelCheckTask
public interface ParallelTask<T>
Interface for any parallel task that can be performed in Scheduler implementations.
Author:
Andreas Schwarte

  • Method Details

    • performTask

      CloseableIteration<T> performTask() throws Exception
      Throws:
      Exception

    • getControl

      ParallelExecutor<T> getControl()
      return the controlling instance, e.g. in most cases the instance of a thread. Shared variables are used to inform the thread about new events.
      Returns:
      the control executor

    • getQueryInfo

      default QueryInfo getQueryInfo()
      Returns:
      the QueryInfo

    • cancel

      void cancel()
      Optional implementation to cancel this task on a best effort basis

    • close

      default void close()
      Optional implementation to close this task on a best effort basis.