org.springframework.yarn.client
Class DefaultApplicationYarnClient

java.lang.Object
  org.springframework.yarn.client.AbstractYarnClient
      org.springframework.yarn.client.CommandYarnClient
          org.springframework.yarn.client.DefaultApplicationYarnClient

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, ApplicationYarnClient, YarnClient

public class DefaultApplicationYarnClient
extends CommandYarnClient
implements ApplicationYarnClient

An implementation of ApplicationYarnClient verifying application install and submit statuses.

Author:

Janne Valkealahti

Constructor Summary

DefaultApplicationYarnClient(ClientRmOperations clientRmOperations)
Instantiates a new default application yarn client.

Method Summary

void	installApplication(ApplicationDescriptor descriptor) Install application based on ApplicationDescriptor.
protected void	postInstallVerify(ApplicationDescriptor descriptor) Post install verify.
protected void	postSubmitVerify(org.apache.hadoop.yarn.api.records.ApplicationId applicationId, ApplicationDescriptor descriptor) Post submit verify.
protected void	preInstallVerify(ApplicationDescriptor descriptor) Pre install verify.
protected void	preSubmitVerify(ApplicationDescriptor descriptor) Pre submit verify.
org.apache.hadoop.yarn.api.records.ApplicationId	submitApplication(ApplicationDescriptor descriptor) Submit application based on ApplicationDescriptor.

Methods inherited from class org.springframework.yarn.client.CommandYarnClient

getEnvironment

Methods inherited from class org.springframework.yarn.client.AbstractYarnClient

afterPropertiesSet, getApplicationReport, getClientRmOperations, getConfiguration, getMasterContainerLaunchContext, getStagingPath, getSubmissionContext, installApplication, killApplication, listApplications, listApplications, listRunningApplications, setApplicationDirName, setAppName, setAppType, setClientRmOperations, setCommands, setConfiguration, setEnvironment, setMemory, setPriority, setQueue, setResourceLocalizer, setStagingDirPath, setVirtualcores, submitApplication, submitApplication

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.yarn.client.YarnClient

getApplicationReport, installApplication, killApplication, listApplications, listApplications, listRunningApplications, submitApplication, submitApplication

Constructor Detail

DefaultApplicationYarnClient

public DefaultApplicationYarnClient(ClientRmOperations clientRmOperations)

Instantiates a new default application yarn client.

Parameters:

clientRmOperations - the client rm operations

Method Detail

installApplication

public void installApplication(ApplicationDescriptor descriptor)

Description copied from interface: ApplicationYarnClient

Install application based on ApplicationDescriptor.

Specified by:

installApplication in interface ApplicationYarnClient

Parameters:

descriptor - the application descriptor

submitApplication

public org.apache.hadoop.yarn.api.records.ApplicationId submitApplication(ApplicationDescriptor descriptor)

Description copied from interface: ApplicationYarnClient

Submit application based on ApplicationDescriptor.

Specified by:

submitApplication in interface ApplicationYarnClient

Parameters:

descriptor - the application descriptor

Returns:

the application id

preInstallVerify

protected void preInstallVerify(ApplicationDescriptor descriptor)

Pre install verify.

Parameters:

descriptor - the application descriptor

postInstallVerify

protected void postInstallVerify(ApplicationDescriptor descriptor)

Post install verify.

Parameters:

descriptor - the application descriptor

preSubmitVerify

protected void preSubmitVerify(ApplicationDescriptor descriptor)

Pre submit verify.

Parameters:

descriptor - the application descriptor

postSubmitVerify

protected void postSubmitVerify(org.apache.hadoop.yarn.api.records.ApplicationId applicationId,
                                ApplicationDescriptor descriptor)

Post submit verify.

Parameters:

applicationId - the application id

descriptor - the application descriptor