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 Summary

    Modifier and Type
    Method
    Description
    void
    cancel()
    Optional implementation to cancel this task on a best effort basis
    default void
    close()
    Optional implementation to close this task on a best effort basis.
    ParallelExecutor<T>
    getControl()
    return the controlling instance, e.g. in most cases the instance of a thread.
    default QueryInfo
    getQueryInfo()
     
    CloseableIteration<T>
    performTask()
     

  • 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.