org.apache.reef.runtime.local.driver

Class ProcessContainer

java.lang.Object

org.apache.reef.runtime.local.driver.ProcessContainer

All Implemented Interfaces:

AutoCloseable, Container

public final class ProcessContainer
extends Object
implements Container

A Container that runs an Evaluator in a Process.

Method Summary

Methods

Modifier and Type	Method and Description
void	addGlobalFiles(File globalFilesFolder)
void	addLocalFiles(Iterable<File> files) Copies the files to the working directory of the container.
void	close() Kills the Container.
String	getContainerID()
File	getFolder()
int	getMemory()
String	getNodeID()
int	getNumberOfCores()
String	getRackName()
boolean	isRunning()
void	run(List<String> commandLine) Run the given commandLine in the container.
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

addLocalFiles

public void addLocalFiles(Iterable<File> files)

Description copied from interface: Container

Copies the files to the working directory of the container.

Specified by:

addLocalFiles in interface Container

Parameters:

files - the files to be added to the container.

addGlobalFiles

public void addGlobalFiles(File globalFilesFolder)

Specified by:

addGlobalFiles in interface Container

run

public void run(List<String> commandLine)

Description copied from interface: Container

Run the given commandLine in the container.

Specified by:

run in interface Container

Parameters:

commandLine - the command line to execute. It will typically be joined by spaces to form the command line.

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Container

Returns:

true if the Container is currently executing, false otherwise.

getMemory

public int getMemory()

Specified by:

getMemory in interface Container

Returns:

the main memory available to the Container.

getNumberOfCores

public int getNumberOfCores()

Specified by:

getNumberOfCores in interface Container

Returns:

the core available to the Container.

getRackName

public String getRackName()

Specified by:

getRackName in interface Container

Returns:

the rack name where this container is located

getFolder

public File getFolder()

Specified by:

getFolder in interface Container

Returns:

the working directory of the Container.

getNodeID

public String getNodeID()

Specified by:

getNodeID in interface Container

Returns:

the ID of the node this Container is executing on.

getContainerID

public String getContainerID()

Specified by:

getContainerID in interface Container

Returns:

the ID of this Container.

close

public void close()

Description copied from interface: Container

Kills the Container.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Container

toString

public String toString()

Overrides:

toString in class Object