Package org.apache.drill.yarn.zk

Class ZKRegistry.DrillbitTracker

java.lang.Object

org.apache.drill.yarn.zk.ZKRegistry.DrillbitTracker

Enclosing class:

ZKRegistry

protected static class ZKRegistry.DrillbitTracker
extends Object

State of each Drillbit that we've discovered through ZK or launched via the AM. The tracker is where we combine the ZK information with AM to correlate overall Drillbit health.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ZKRegistry.DrillbitTracker.State	A Drillbit can be in one of four states.

Field Summary

Fields

Modifier and Type	Field	Description
protected CoordinationProtos.DrillbitEndpoint	endpoint	For Drillbits discovered through ZK, the Drill endpoint for the Drillbit.
protected final String	key	The common key used between tasks and ZK registrations.
protected ZKRegistry.DrillbitTracker.State	state	ZK tracking state.
protected Task	task	For Drillbits started by the AM, the task object for this Drillbit.

Constructor Summary

Constructors

Constructor	Description
DrillbitTracker(String key, CoordinationProtos.DrillbitEndpoint endpoint)
DrillbitTracker(String key, Task task)

Method Summary

Modifier and Type	Method	Description
void	becomeUnregistered()	Mark that a YARN-managed Drillbit has dropped out of ZK.

Methods inherited from class java.lang.Object

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

Field Details

key

protected final String key

The common key used between tasks and ZK registrations. The key is of the form:

 host:port:port:port
 

state

protected ZKRegistry.DrillbitTracker.State state

ZK tracking state. See ZKRegistry.DrillbitTracker.State

task

protected Task task

For Drillbits started by the AM, the task object for this Drillbit.

endpoint

protected CoordinationProtos.DrillbitEndpoint endpoint

For Drillbits discovered through ZK, the Drill endpoint for the Drillbit.

Constructor Details

DrillbitTracker

public DrillbitTracker(String key,
 CoordinationProtos.DrillbitEndpoint endpoint)

DrillbitTracker

public DrillbitTracker(String key,
 Task task)

Method Details

becomeUnregistered

public void becomeUnregistered()

Mark that a YARN-managed Drillbit has dropped out of ZK.