Package org.apache.drill.exec.work.foreman

Class QueryManager

java.lang.Object

org.apache.drill.exec.work.foreman.QueryManager

All Implemented Interfaces:

AutoCloseable

public class QueryManager
extends Object
implements AutoCloseable

Each Foreman holds its own QueryManager. This manages the events associated with execution of a particular query across all fragments.

Constructor Summary

Constructors

Constructor	Description
QueryManager(UserBitShared.QueryId queryId, UserProtos.RunQuery runQuery, PersistentStoreProvider storeProvider, ClusterCoordinator coordinator, Foreman foreman)

Method Summary

Modifier and Type	Method	Description
void	close()
DrillbitStatusListener	getDrillbitStatusListener()
String	getFragmentStatesAsString()
FragmentStatusListener	getFragmentStatusListener()
UserBitShared.QueryProfile	getQueryProfile()
void	setQueueName(String queueName)
void	setTotalCost(double totalCost)

Methods inherited from class java.lang.Object

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

Constructor Details

QueryManager

public QueryManager(UserBitShared.QueryId queryId,
 UserProtos.RunQuery runQuery,
 PersistentStoreProvider storeProvider,
 ClusterCoordinator coordinator,
 Foreman foreman)

Method Details

getFragmentStatesAsString

public String getFragmentStatesAsString()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getQueryProfile

public UserBitShared.QueryProfile getQueryProfile()

setTotalCost

public void setTotalCost(double totalCost)

setQueueName

public void setQueueName(String queueName)

getFragmentStatusListener

public FragmentStatusListener getFragmentStatusListener()

getDrillbitStatusListener

public DrillbitStatusListener getDrillbitStatusListener()