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 and Description
static class	ZKRegistry.DrillbitTracker.State A Drillbit can be in one of four states.

Field Summary

Fields

Modifier and Type	Field and Description
protected CoordinationProtos.DrillbitEndpoint	endpoint For Drillbits discovered through ZK, the Drill endpoint for the Drillbit.
protected 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 and Description
DrillbitTracker(String key, CoordinationProtos.DrillbitEndpoint endpoint)
DrillbitTracker(String key, Task task)

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

DrillbitTracker

public DrillbitTracker(String key,
                       CoordinationProtos.DrillbitEndpoint endpoint)

DrillbitTracker

public DrillbitTracker(String key,
                       Task task)

Method Detail

becomeUnregistered

public void becomeUnregistered()

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