Package org.apache.druid.query

Class DirectQueryProcessingPool

java.lang.Object
com.google.common.collect.ForwardingObject
com.google.common.util.concurrent.ForwardingExecutorService
com.google.common.util.concurrent.ForwardingListeningExecutorService
org.apache.druid.query.DirectQueryProcessingPool
All Implemented Interfaces:
com.google.common.util.concurrent.ListeningExecutorService, Executor, ExecutorService, QueryProcessingPool
public class DirectQueryProcessingPool extends com.google.common.util.concurrent.ForwardingListeningExecutorService implements QueryProcessingPool
QueryProcessingPool wrapper over Execs.directExecutor()

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static DirectQueryProcessingPool
    INSTANCE
     

  • Method Summary

    Modifier and Type
    Method
    Description
    com.google.common.util.concurrent.ListeningExecutorService
    delegate()
     
    <T, V> com.google.common.util.concurrent.ListenableFuture<T>
    submitRunnerTask(PrioritizedQueryRunnerCallable<T,V> task)
    Submits the query execution unit task for asynchronous execution.
    <T, V> com.google.common.util.concurrent.ListenableFuture<T>
    submitRunnerTask(PrioritizedQueryRunnerCallable<T,V> task, long timeout, TimeUnit unit)
    Submits the query execution task for asynchronous execution, with a provided timeout.

    Methods inherited from class com.google.common.util.concurrent.ForwardingListeningExecutorService

    submit, submit, submit

    Methods inherited from class com.google.common.util.concurrent.ForwardingExecutorService

    awaitTermination, execute, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow

    Methods inherited from class com.google.common.collect.ForwardingObject

    toString

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    Methods inherited from interface java.util.concurrent.Executor

    execute

    Methods inherited from interface java.util.concurrent.ExecutorService

    awaitTermination, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow

    Methods inherited from interface com.google.common.util.concurrent.ListeningExecutorService

    awaitTermination, invokeAll, invokeAll, invokeAll, invokeAny, submit, submit, submit

  • Field Details

  • Method Details

    • submitRunnerTask

      public <T, V> com.google.common.util.concurrent.ListenableFuture<T> submitRunnerTask(PrioritizedQueryRunnerCallable<T,V> task)
      Description copied from interface: QueryProcessingPool
      Submits the query execution unit task for asynchronous execution.
      Specified by:
      submitRunnerTask in interface QueryProcessingPool
      Type Parameters:
      T - - Task result type
      V - - Query runner sequence type
      Parameters:
      task - - Task to be submitted.
      Returns:
      - Future object for tracking the task completion.

    • submitRunnerTask

      public <T, V> com.google.common.util.concurrent.ListenableFuture<T> submitRunnerTask(PrioritizedQueryRunnerCallable<T,V> task, long timeout, TimeUnit unit)
      Description copied from interface: QueryProcessingPool
      Submits the query execution task for asynchronous execution, with a provided timeout.
      Specified by:
      submitRunnerTask in interface QueryProcessingPool
      Type Parameters:
      T - - Task result type
      V - - Query runner sequence type
      Parameters:
      task - - Task to be submitted.
      timeout - - Timeout value
      unit - - Timeout unit
      Returns:
      - Future object for tracking the task completion.

    • delegate

      public com.google.common.util.concurrent.ListeningExecutorService delegate()
      Specified by:
      delegate in class com.google.common.util.concurrent.ForwardingListeningExecutorService