ControllerModel (Drill : 1.19.0 API)

java.lang.Object
- org.apache.drill.yarn.appMaster.http.ControllerModel

All Implemented Interfaces:: ControllerVisitor

public class ControllerModel
extends Object
implements ControllerVisitor

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class ControllerModel.ClusterGroupModel

Nested Classes
Modifier and Type	Class and Description
`static class`	`ControllerModel.ClusterGroupModel`

Field Summary

Fields
Modifier and Type	Field and Description
`protected AMYarnFacade.YarnAppHostReport`	`appRpt`
`protected int`	`blacklistCount`
`protected int`	`freeNodeCount`
`protected List<ControllerModel.ClusterGroupModel>`	`groups`
`protected int`	`liveCount`
`protected int`	`refreshSecs`
`protected ClusterControllerImpl.State`	`state`
`protected String`	`stateHint`
`protected boolean`	`supportsDisks`
`protected int`	`targetCount`
`protected int`	`taskCount`
`protected double`	`totalDrillDisks`
`protected int`	`totalDrillMemory`
`protected int`	`totalDrillVcores`
`protected int`	`unmanagedCount`
`protected int`	`yarnMemory`
`protected int`	`yarnNodeCount`
`protected int`	`yarnVcores`
`protected String`	`zkClusterId`
`protected String`	`zkConnectStr`
`protected String`	`zkRoot`

Constructor Summary

Constructors
Constructor and Description

ControllerModel()

Constructors
Constructor and Description
`ControllerModel()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`countStrayDrillbits(ClusterController controller)` Count the unmanaged drillbits.
`String`	`getAppId()`
`int`	`getBlacklistCount()`
`String`	`getDrillTotalDisks()`
`int`	`getDrillTotalMemory()`
`int`	`getDrillTotalVcores()`
`int`	`getFreeNodeCount()`
`List<ControllerModel.ClusterGroupModel>`	`getGroups()`
`int`	`getLiveCount()`
`String`	`getNmAppLink()`
`String`	`getNmHost()`
`String`	`getNmLink()`
`int`	`getRefreshSecs()`
`String`	`getRmAppLink()`
`String`	`getRmHost()`
`String`	`getRmLink()`
`String`	`getState()`
`String`	`getStateHint()`
`int`	`getTargetCount()`
`int`	`getTaskCount()`
`int`	`getUnmanagedCount()`
`int`	`getYarnMemory()`
`int`	`getYarnNodeCount()`
`int`	`getYarnVcores()`
`String`	`getZkClusterId()`
`String`	`getZkConnectionStr()`
`String`	`getZkRoot()`
`boolean`	`supportsDiskResource()`
`void`	`visit(ClusterController controller)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

zkConnectStr
```
protected String zkConnectStr
```

zkRoot
```
protected String zkRoot
```

zkClusterId
```
protected String zkClusterId
```

state

protected ClusterControllerImpl.State state

stateHint
```
protected String stateHint
```

supportsDisks
```
protected boolean supportsDisks
```

yarnMemory
```
protected int yarnMemory
```

yarnVcores
```
protected int yarnVcores
```

yarnNodeCount
```
protected int yarnNodeCount
```

taskCount
```
protected int taskCount
```

liveCount
```
protected int liveCount
```

unmanagedCount
```
protected int unmanagedCount
```

targetCount
```
protected int targetCount
```

totalDrillMemory
```
protected int totalDrillMemory
```

totalDrillVcores
```
protected int totalDrillVcores
```

totalDrillDisks
```
protected double totalDrillDisks
```

blacklistCount
```
protected int blacklistCount
```

freeNodeCount
```
protected int freeNodeCount
```

appRpt

protected AMYarnFacade.YarnAppHostReport appRpt

refreshSecs
```
protected int refreshSecs
```

groups

protected List<ControllerModel.ClusterGroupModel> groups

Constructor Detail
- ControllerModel
```
public ControllerModel()
```

Method Detail

supportsDiskResource
```
public boolean supportsDiskResource()
```

getRefreshSecs
```
public int getRefreshSecs()
```

getZkConnectionStr
```
public String getZkConnectionStr()
```

getZkRoot
```
public String getZkRoot()
```

getZkClusterId
```
public String getZkClusterId()
```

getAppId
```
public String getAppId()
```

getRmHost
```
public String getRmHost()
```

getRmLink
```
public String getRmLink()
```

getNmHost
```
public String getNmHost()
```

getNmLink
```
public String getNmLink()
```

getRmAppLink
```
public String getRmAppLink()
```

getNmAppLink
```
public String getNmAppLink()
```

getState
```
public String getState()
```

getStateHint
```
public String getStateHint()
```

getYarnMemory
```
public int getYarnMemory()
```

getYarnVcores
```
public int getYarnVcores()
```

getDrillTotalMemory
```
public int getDrillTotalMemory()
```

getDrillTotalVcores
```
public int getDrillTotalVcores()
```

getDrillTotalDisks
```
public String getDrillTotalDisks()
```

getYarnNodeCount
```
public int getYarnNodeCount()
```

getTaskCount
```
public int getTaskCount()
```

getLiveCount
```
public int getLiveCount()
```

getUnmanagedCount
```
public int getUnmanagedCount()
```

getTargetCount
```
public int getTargetCount()
```

getGroups

public List<ControllerModel.ClusterGroupModel> getGroups()

getBlacklistCount
```
public int getBlacklistCount()
```

getFreeNodeCount
```
public int getFreeNodeCount()
```

visit

public void visit(ClusterController controller)

Specified by:: visit in interface ControllerVisitor

countStrayDrillbits
```
public void countStrayDrillbits(ClusterController controller)
```
Count the unmanaged drillbits. Do this as a separate call, not via the visit method, to avoid locking both the cluster controller and ZK registry.

Parameters:

controller -

Class ControllerModel

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

zkConnectStr

zkRoot

zkClusterId

state

stateHint

supportsDisks

yarnMemory

yarnVcores

yarnNodeCount

taskCount

liveCount

unmanagedCount

targetCount

totalDrillMemory

totalDrillVcores

totalDrillDisks

blacklistCount

freeNodeCount

appRpt

refreshSecs

groups

Constructor Detail

ControllerModel

Method Detail

supportsDiskResource

getRefreshSecs

getZkConnectionStr

getZkRoot

getZkClusterId

getAppId

getRmHost

getRmLink

getNmHost

getNmLink

getRmAppLink

getNmAppLink

getState

getStateHint

getYarnMemory

getYarnVcores

getDrillTotalMemory

getDrillTotalVcores

getDrillTotalDisks

getYarnNodeCount

getTaskCount

getLiveCount

getUnmanagedCount

getTargetCount

getGroups

getBlacklistCount

getFreeNodeCount

visit

countStrayDrillbits