Package org.apache.drill.yarn.appMaster.http

Class AbstractTasksModel.TasksModel

java.lang.Object

org.apache.drill.yarn.appMaster.http.AbstractTasksModel

org.apache.drill.yarn.appMaster.http.AbstractTasksModel.TasksModel

All Implemented Interfaces:

TaskVisitor

Enclosing class:

AbstractTasksModel

public static class AbstractTasksModel.TasksModel
extends AbstractTasksModel
implements TaskVisitor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.yarn.appMaster.http.AbstractTasksModel

AbstractTasksModel.HistoryModel, AbstractTasksModel.TaskModel, AbstractTasksModel.TasksModel, AbstractTasksModel.UnmanagedDrillbitModel

Field Summary

Fields

Modifier and Type	Field	Description
protected List<String>	blacklist
protected List<AbstractTasksModel.UnmanagedDrillbitModel>	unmanaged

Fields inherited from class org.apache.drill.yarn.appMaster.http.AbstractTasksModel

results, supportsDisks

Constructor Summary

Constructors

Constructor	Description
TasksModel()

Method Summary

Modifier and Type	Method	Description
List<String>	getBlacklist()
int	getBlacklistCount()
int	getUnmanagedDrillbitCount()
List<AbstractTasksModel.UnmanagedDrillbitModel>	getUnnamaged()
boolean	hasBlacklist()
boolean	hasUnmanagedDrillbits()
void	listAnomalies(ClusterController controller)	List any anomalies: either stray Drillbits (those in ZK but not launched by DoY), or blacklisted nodes.
void	sortTasks()	Sort tasks by Task ID.
void	visit(Task task)

Methods inherited from class org.apache.drill.yarn.appMaster.http.AbstractTasksModel

getTasks, hasTasks, supportsDiskResource

Methods inherited from class java.lang.Object

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

Field Details

unmanaged

protected List<AbstractTasksModel.UnmanagedDrillbitModel> unmanaged

blacklist

protected List<String> blacklist

Constructor Details

TasksModel

public TasksModel()

Method Details

visit

public void visit(Task task)

Specified by:

visit in interface TaskVisitor

sortTasks

public void sortTasks()

Sort tasks by Task ID.

listAnomalies

public void listAnomalies(ClusterController controller)

List any anomalies: either stray Drillbits (those in ZK but not launched by DoY), or blacklisted nodes.

To avoid race conditions, do not use the controller visitor to invoke this method, we want to leave the controller unlocked and instead lock only the ZK registry.

Parameters:

controller -

getUnnamaged

public List<AbstractTasksModel.UnmanagedDrillbitModel> getUnnamaged()

hasUnmanagedDrillbits

public boolean hasUnmanagedDrillbits()

getUnmanagedDrillbitCount

public int getUnmanagedDrillbitCount()

hasBlacklist

public boolean hasBlacklist()

getBlacklistCount

public int getBlacklistCount()

getBlacklist

public List<String> getBlacklist()