io.druid.server

Class QueryManager

java.lang.Object

io.druid.server.QueryManager

All Implemented Interfaces:

QueryWatcher

public class QueryManager
extends Object
implements QueryWatcher

Constructor Summary

Constructors

Constructor and Description
QueryManager()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancelQuery(String id)
void	registerQuery(Query query, com.google.common.util.concurrent.ListenableFuture future) QueryRunners must use this method to register any pending queries.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryManager

public QueryManager()

Method Detail

cancelQuery

public boolean cancelQuery(String id)

registerQuery

public void registerQuery(Query query,
                 com.google.common.util.concurrent.ListenableFuture future)

Description copied from interface: QueryWatcher

QueryRunners must use this method to register any pending queries. The given future may have cancel(true) called at any time, if cancellation of this query has been requested.

Specified by:

registerQuery in interface QueryWatcher

Parameters:

query - a query, which may be a subset of a larger query, as long as the underlying queryId is unchanged

future - the future holding the execution status of the query