org.apache.ignite.yarn

Class ApplicationMaster

java.lang.Object

org.apache.ignite.yarn.ApplicationMaster

All Implemented Interfaces:

AMRMClientAsync.CallbackHandler

public class ApplicationMaster
extends Object
implements AMRMClientAsync.CallbackHandler

Application master request containers from Yarn and decides how many resources will be occupied.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_PORT Default port range.
static String	DELIM Delimiter char.
static Logger	log

Constructor Summary

Constructors

Constructor and Description
ApplicationMaster(String ignitePath, ClusterProperties props)

Method Summary

Modifier and Type	Method and Description
Map<ContainerId,IgniteContainer>	getContainers() Deprecated.
float	getProgress()
void	init()
static void	main(String[] args)
void	onContainersAllocated(List<Container> conts)
void	onContainersCompleted(List<ContainerStatus> statuses)
void	onError(Throwable t)
void	onNodesUpdated(List<NodeReport> updated)
void	onShutdownRequest()
void	run() Runs application master.
void	setFs(FileSystem fs) Sets file system.
void	setNmClient(NMClient nmClient) Sets NMClient.
void	setRmClient(AMRMClientAsync<AMRMClient.ContainerRequest> rmClient) Sets RMClient
void	setSchedulerTimeout(long schedulerTimeout) Sets scheduler timeout.

Methods inherited from class java.lang.Object

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

Field Detail

log

public static final Logger log

DEFAULT_PORT

public static final String DEFAULT_PORT

Default port range.

See Also:

Constant Field Values

DELIM

public static final String DELIM

Delimiter char.

See Also:

Constant Field Values

Constructor Detail

ApplicationMaster

public ApplicationMaster(String ignitePath,
                         ClusterProperties props)
                  throws Exception

Parameters:

ignitePath - Hdfs path to ignite.

props - Cluster properties.

Throws:

Exception

Method Detail

onContainersAllocated

public void onContainersAllocated(List<Container> conts)

Specified by:

onContainersAllocated in interface AMRMClientAsync.CallbackHandler

onContainersCompleted

public void onContainersCompleted(List<ContainerStatus> statuses)

Specified by:

onContainersCompleted in interface AMRMClientAsync.CallbackHandler

onNodesUpdated

public void onNodesUpdated(List<NodeReport> updated)

Specified by:

onNodesUpdated in interface AMRMClientAsync.CallbackHandler

onShutdownRequest

public void onShutdownRequest()

Specified by:

onShutdownRequest in interface AMRMClientAsync.CallbackHandler

onError

public void onError(Throwable t)

Specified by:

onError in interface AMRMClientAsync.CallbackHandler

getProgress

public float getProgress()

Specified by:

getProgress in interface AMRMClientAsync.CallbackHandler

main

public static void main(String[] args)
                 throws Exception

Parameters:

args - Args.

Throws:

Exception - If failed.

run

public void run()
         throws Exception

Runs application master.

Throws:

Exception - If failed.

init

public void init()
          throws IOException

Throws:

IOException

setNmClient

public void setNmClient(NMClient nmClient)

Sets NMClient.

Parameters:

nmClient - NMClient.

setRmClient

public void setRmClient(AMRMClientAsync<AMRMClient.ContainerRequest> rmClient)

Sets RMClient

Parameters:

rmClient - AMRMClientAsync.

setSchedulerTimeout

public void setSchedulerTimeout(long schedulerTimeout)

Sets scheduler timeout.

Parameters:

schedulerTimeout - Scheduler timeout.

setFs

public void setFs(FileSystem fs)

Sets file system.

Parameters:

fs - File system.

getContainers

@Deprecated
public Map<ContainerId,IgniteContainer> getContainers()

Deprecated.

JUST FOR TESTING!!!

Returns:

Running containers.