Class ZKClusterCoordinatorDriver

java.lang.Object
org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver
All Implemented Interfaces:
AMRegistrar

public class ZKClusterCoordinatorDriver extends Object implements AMRegistrar
Driver class for the ZooKeeper cluster coordinator. Provides defaults for most options, but allows customizing each. Provides a build() method to create and start the ZK service. Obtains the initial set of Drillbits (which should be empty for a YARN-defined cluster) which can be retrieved after building.

Maintains the ZK connection and monitors for disconnect. This class simply detects a disconnect timeout, it does not send a disconnect event itself to avoid creating a timer thread just for this purpose. Instead, the caller can poll hasFailed().

Defaults match those in Drill. (Actual Drill defaults are not yet used due to code incompatibility issues.)