Package org.apache.drill.yarn.appMaster
package org.apache.drill.yarn.appMaster
Implements the Drill Application Master for YARN.
Note that AM implementation classes use org.apache.commons.logging
to be consistent with the logging used within YARN itself. However,
the AM uses Drill's class path which uses logback logging. To enable
logging, modify
$DRILL_HOME/conf/logback.xml
and add a section something
like this:
<logger name="org.apache.drill.yarn" additivity="false">
<level value="trace" />
<appender-ref ref="STDOUT" />
</logger>
-
ClassDescriptionBase class for schedulers (pools) for Drillbits.Task manager that does nothing.Interface to register the AM.Defines the interface between the Application Master and YARN.Provides a collection of web UI links for the YARN Resource Manager and the Node Manager that is running the Drill-on-YARN AM.Wrapper around the asynchronous versions of the YARN AM-RM and AM-NM interfaces.Interface which identifies the cluster controller methods that are save to call from the
Dispatcher
.Controls the Drill cluster by representing the current cluster state with a desired state, taking corrective action to keep the cluster in the desired state.Controller lifecycle state.Dispatches YARN, timer and ZooKeeper events to the cluster controller.Interface for an add-on to the dispatcher that should be started at start of the run and ended at the end of the run.Application Master for Drill.Builds a controller for a cluster of Drillbits.Creates an AM-side inventory of cluster nodes.Abstract base class for schedulers that work with persistent (long-running) tasks.Interface for objects that are polled on each controller clock tick in order to perform time-based tasks.Clock driver that calls a callback once each pulse period.Interface implemented to receive calls on each clock "tick."Callback from the ZooKeeper registry to announce events related to Drillbit registration.The scheduler describes the set of tasks to run.The cluster state for tasks managed by a scheduler.Represents the set of commands called by the cluster controller to manage the state of tasks within a task group.Manages a the set of tasks associated with a scheduler.AM-side state of individual containers.Tracking plugin state.Represents the behaviors associated with each state in the lifecycle of a task.Task for which a termination request has been sent to the Drill-bit, but confirmation has not yet been received from the Node Manager.Task for which a forced termination request has been sent to the Node Manager, but a stop message has not yet been received.Exceptions thrown from the YARN facade: the wrapper around the YARN AM interfaces.