org.springframework.yarn.client

Class YarnClientFactoryBean

java.lang.Object

org.springframework.yarn.client.YarnClientFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<YarnClient>, org.springframework.beans.factory.InitializingBean

public class YarnClientFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.FactoryBean<YarnClient>

Factory bean building YarnClient instances.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
YarnClientFactoryBean()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
YarnClient	getObject()
java.lang.Class<YarnClient>	getObjectType()
boolean	isSingleton()
void	setAppName(java.lang.String appName) Sets the name for submitted application.
void	setAppType(java.lang.String appType) Sets the type for submitted application.
void	setClientClass(java.lang.Class<? extends YarnClient> clientClass) Sets the client class.
void	setCommands(java.util.List<java.lang.String> commands) Sets the commands starting appmaster.
void	setCommands(java.lang.String[] commands) Sets the commands starting appmaster.
void	setConfiguration(org.apache.hadoop.conf.Configuration configuration) Sets the Yarn configuration.
void	setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment) Sets the environment for appmaster.
void	setMemory(int memory) Sets the memory.
void	setPriority(int priority) Sets the priority.
void	setQueue(java.lang.String queue) Sets the queue.
void	setResourceLocalizer(ResourceLocalizer resourceLocalizer) Sets the resource localizer for appmaster container.
void	setTemplate(ClientRmOperations template)
void	setVirtualcores(int virtualcores) Sets the virtualcores.

Methods inherited from class java.lang.Object

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

Constructor Detail

YarnClientFactoryBean

public YarnClientFactoryBean()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

getObject

public YarnClient getObject()
                     throws java.lang.Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<YarnClient>

Throws:

java.lang.Exception

getObjectType

public java.lang.Class<YarnClient> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<YarnClient>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<YarnClient>

setClientClass

public void setClientClass(java.lang.Class<? extends YarnClient> clientClass)

Sets the client class.

Parameters:

clientClass - the new client class

setConfiguration

public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)

Sets the Yarn configuration.

Parameters:

configuration - the Yarn configuration

setEnvironment

public void setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment)

Sets the environment for appmaster.

Parameters:

environment - the environment

setCommands

public void setCommands(java.util.List<java.lang.String> commands)

Sets the commands starting appmaster.

Parameters:

commands - the commands starting appmaster

setCommands

public void setCommands(java.lang.String[] commands)

Sets the commands starting appmaster.

Parameters:

commands - the commands starting appmaster

setResourceLocalizer

public void setResourceLocalizer(ResourceLocalizer resourceLocalizer)

Sets the resource localizer for appmaster container.

Parameters:

resourceLocalizer - the new resource localizer

setAppName

public void setAppName(java.lang.String appName)

Sets the name for submitted application.

Parameters:

appName - the new application name

setAppType

public void setAppType(java.lang.String appType)

Sets the type for submitted application.

Parameters:

appType - the new application type

setPriority

public void setPriority(int priority)

Sets the priority.

Parameters:

priority - the new priority

setVirtualcores

public void setVirtualcores(int virtualcores)

Sets the virtualcores.

Parameters:

virtualcores - the new virtualcores

setMemory

public void setMemory(int memory)

Sets the memory.

Parameters:

memory - the new memory

setQueue

public void setQueue(java.lang.String queue)

Sets the queue.

Parameters:

queue - the new queue

setTemplate

public void setTemplate(ClientRmOperations template)