Package org.apache.druid.sql

Class SqlLifecycleManager

java.lang.Object

org.apache.druid.sql.SqlLifecycleManager

public class SqlLifecycleManager
extends Object

This class manages only authorized DirectStatements submitted via HTTP, such as SqlResource. The main use case of this class is tracking running queries so that the cancel API can identify the statements to cancel. This class is thread-safe as there are 2 or more threads that can access statements at the same time for query running or query canceling. For managing and canceling native queries, see QueryScheduler. As its name indicates, it also performs resource scheduling for native queries based on query lanes QueryLaningStrategy.

See Also:

• QueryScheduler.cancelQuery(String)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SqlLifecycleManager.Cancelable

Constructor Summary

Constructors

Constructor	Description
SqlLifecycleManager()

Method Summary

Modifier and Type	Method	Description
void	add(String sqlQueryId, SqlLifecycleManager.Cancelable lifecycle)
List<SqlLifecycleManager.Cancelable>	getAll(String sqlQueryId)	Returns a snapshot of the lifecycles for the given sqlQueryId.
void	remove(String sqlQueryId, SqlLifecycleManager.Cancelable lifecycle)	Removes the given lifecycle of the given query ID.
void	removeAll(String sqlQueryId, List<SqlLifecycleManager.Cancelable> lifecyclesToRemove)	For the given sqlQueryId, this method removes all lifecycles that match to the given list of lifecycles.

Methods inherited from class java.lang.Object

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

Constructor Details

SqlLifecycleManager

public SqlLifecycleManager()

Method Details

add

public void add(String sqlQueryId,
 SqlLifecycleManager.Cancelable lifecycle)

remove

public void remove(String sqlQueryId,
 SqlLifecycleManager.Cancelable lifecycle)

Removes the given lifecycle of the given query ID. This method uses Object.equals(java.lang.Object) to find the lifecycle matched to the given parameter.

removeAll

public void removeAll(String sqlQueryId,
 List<SqlLifecycleManager.Cancelable> lifecyclesToRemove)

For the given sqlQueryId, this method removes all lifecycles that match to the given list of lifecycles. This method uses Object.equals(java.lang.Object) for matching lifecycles.

getAll

public List<SqlLifecycleManager.Cancelable> getAll(String sqlQueryId)

Returns a snapshot of the lifecycles for the given sqlQueryId.