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.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	AMYarnFacade.YarnAppHostReport Provides a collection of web UI links for the YARN Resource Manager and the Node Manager that is running the Drill-on-YARN AM.

Method Summary

Modifier and Type	Method and Description
void	blacklistNode(String nodeName)
void	finish(boolean success, String msg)
AMYarnFacade.YarnAppHostReport	getAppHostReport()
int	getNodeCount()
List<org.apache.hadoop.yarn.api.records.NodeReport>	getNodeReports()
org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse	getRegistrationResponse()
org.apache.hadoop.yarn.api.records.Resource	getResources()
String	getTrackingUrl()
void	killContainer(org.apache.hadoop.yarn.api.records.Container container)
void	launchContainer(org.apache.hadoop.yarn.api.records.Container container, LaunchSpec taskSpec)
void	register(String trackingUrl)
void	releaseContainer(org.apache.hadoop.yarn.api.records.Container container)
void	removeBlacklist(String nodeName)
void	removeContainerRequest(org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest containerRequest)
org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest	requestContainer(ContainerRequestSpec containerSpec)
void	start(org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler resourceCallback, org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler nodeCallback)
boolean	supportsDiskResource()

Method Detail

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()