Package org.apache.drill.exec.work

Class WorkManager

java.lang.Object

org.apache.drill.exec.work.WorkManager

All Implemented Interfaces:

AutoCloseable

public class WorkManager
extends Object
implements AutoCloseable

Manages the running fragments in a Drillbit. Periodically requests run-time stats updates from fragments running elsewhere.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	WorkManager.WorkerBee	Narrowed interface to WorkManager that is made available to tasks it is managing.

Constructor Summary

Constructors

Constructor	Description
WorkManager(BootStrapContext context)

Method Summary

Modifier and Type	Method	Description
void	close()
WorkManager.WorkerBee	getBee()
DrillbitContext	getContext()
ControlMessageHandler	getControlMessageHandler()
Executor	getExecutor()
Map<String,Integer>	getRemainingQueries()	Get the number of queries that are running on a drillbit.
UserWorker	getUserWorker()
WorkEventBus	getWorkBus()
void	start(CoordinationProtos.DrillbitEndpoint endpoint, Controller controller, DataConnectionCreator data, ClusterCoordinator coord, PersistentStoreProvider provider, PersistentStoreProvider profilesProvider)
void	waitToExit(boolean forcefulShutdown)

Methods inherited from class java.lang.Object

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

Constructor Details

WorkManager

public WorkManager(BootStrapContext context)

Method Details

start

public void start(CoordinationProtos.DrillbitEndpoint endpoint,
 Controller controller,
 DataConnectionCreator data,
 ClusterCoordinator coord,
 PersistentStoreProvider provider,
 PersistentStoreProvider profilesProvider)

getExecutor

public Executor getExecutor()

getWorkBus

public WorkEventBus getWorkBus()

getControlMessageHandler

public ControlMessageHandler getControlMessageHandler()

getUserWorker

public UserWorker getUserWorker()

getBee

public WorkManager.WorkerBee getBee()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getContext

public DrillbitContext getContext()

waitToExit

public void waitToExit(boolean forcefulShutdown)

getRemainingQueries

public Map<String,Integer> getRemainingQueries()

Get the number of queries that are running on a drillbit. Primarily used to monitor the number of running queries after a shutdown request is triggered.