Package org.apache.druid.query

Interface PrioritizedQueryRunnerCallable<T,V>

Type Parameters:
T - - Type of result of Callable.call() method
V - - Type of Sequence of rows returned by QueryRunner
All Superinterfaces:
Callable<T>, PrioritizedCallable<T>
All Known Implementing Classes:
AbstractPrioritizedQueryRunnerCallable
public interface PrioritizedQueryRunnerCallable<T,V> extends PrioritizedCallable<T>
An implementation of PrioritizedCallable that also lets caller get access to associated QueryRunner It is used in implementations of QueryRunnerFactory

  • Method Summary

    Modifier and Type
    Method
    Description
    QueryRunner<V>
    getRunner()
    This method can be used by the extensions to get the runner that the given query execution task corresponds to.

    Methods inherited from interface java.util.concurrent.Callable

    call

    Methods inherited from interface org.apache.druid.query.PrioritizedCallable

    getPriority

  • Method Details

    • getRunner

      QueryRunner<V> getRunner()
      This method can be used by the extensions to get the runner that the given query execution task corresponds to. That in turn can be used to fetch any state associated with the QueryRunner such as the segment info for example. Extensions can carry any state from custom implementation of QuerySegmentWalker to a custom implementation of QueryProcessingPool.submitRunnerTask(PrioritizedQueryRunnerCallable)