Package org.apache.drill.yarn.appMaster

Interface AMYarnFacade

All Known Implementing Classes:
AMYarnFacadeImpl
public interface AMYarnFacade
Defines the interface between the Application Master and YARN. This interface enables the use of a mock implementation for testing as well as the actual implementation that works with YARN.

  • Method Details

    • start

      void start(org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler resourceCallback, org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler nodeCallback)

    • register

      void register(String trackingUrl) throws YarnFacadeException
      Throws:
      YarnFacadeException

    • getTrackingUrl

      String getTrackingUrl()

    • requestContainer

      org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest requestContainer(ContainerRequestSpec containerSpec)

    • removeContainerRequest

      void removeContainerRequest(org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest containerRequest)

    • launchContainer

      void launchContainer(org.apache.hadoop.yarn.api.records.Container container, LaunchSpec taskSpec) throws YarnFacadeException
      Throws:
      YarnFacadeException

    • finish

      void finish(boolean success, String msg) throws YarnFacadeException
      Throws:
      YarnFacadeException

    • releaseContainer

      void releaseContainer(org.apache.hadoop.yarn.api.records.Container container)

    • killContainer

      void killContainer(org.apache.hadoop.yarn.api.records.Container container)

    • getNodeCount

      int getNodeCount()

    • getResources

      org.apache.hadoop.yarn.api.records.Resource getResources()

    • getRegistrationResponse

      org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse getRegistrationResponse()

    • blacklistNode

      void blacklistNode(String nodeName)

    • removeBlacklist

      void removeBlacklist(String nodeName)

    • getNodeReports

      List<org.apache.hadoop.yarn.api.records.NodeReport> getNodeReports() throws YarnFacadeException
      Throws:
      YarnFacadeException

    • getAppHostReport

      AMYarnFacade.YarnAppHostReport getAppHostReport()

    • supportsDiskResource

      boolean supportsDiskResource()