Package org.apache.druid.query

Class AbstractPrioritizedQueryRunnerCallable<T,V>

java.lang.Object

org.apache.druid.query.AbstractPrioritizedQueryRunnerCallable<T,V>

Type Parameters:

T -

V -

All Implemented Interfaces:

Callable<T>, PrioritizedCallable<T>, PrioritizedQueryRunnerCallable<T,V>

public abstract class AbstractPrioritizedQueryRunnerCallable<T,V>
extends Object
implements PrioritizedQueryRunnerCallable<T,V>

A helper class to avoid boilerplate for creating PrioritizedQueryRunnerCallable objects.

Constructor Summary

Constructors

Constructor	Description
AbstractPrioritizedQueryRunnerCallable(int priority, QueryRunner<V> runner)

Method Summary

Modifier and Type	Method	Description
int	getPriority()
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 class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Callable

call

Constructor Details

AbstractPrioritizedQueryRunnerCallable

public AbstractPrioritizedQueryRunnerCallable(int priority,
 QueryRunner<V> runner)

Method Details

getRunner

public QueryRunner<V> getRunner()

Description copied from interface: PrioritizedQueryRunnerCallable

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)

Specified by:

getRunner in interface PrioritizedQueryRunnerCallable<T,V>

getPriority

public int getPriority()

Specified by:

getPriority in interface PrioritizedCallable<T>