org.apache.giraph.yarn

Class GiraphYarnClient

java.lang.Object

org.apache.giraph.yarn.GiraphYarnClient

public class GiraphYarnClient
extends Object

The initial launcher for a YARN-based Giraph job. This class attempts to configure and send a request to the ResourceManager for a single application container to host GiraphApplicationMaster. The RPC connection between the RM and GiraphYarnClient is the YARN ApplicationManager.

Constructor Summary

Constructors

Constructor and Description
GiraphYarnClient(GiraphConfiguration giraphConf, String jobName) Constructor.

Method Summary

Modifier and Type	Method and Description
boolean	run(boolean verbose) Submit a request to the Hadoop YARN cluster's ResourceManager to obtain an application container.

Methods inherited from class java.lang.Object

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

Constructor Detail

GiraphYarnClient

public GiraphYarnClient(GiraphConfiguration giraphConf,
                        String jobName)
                 throws IOException

Constructor. Requires caller to hand us a GiraphConfiguration.

Parameters:

giraphConf - User-defined configuration

jobName - User-defined job name

Throws:

IOException

Method Detail

run

public boolean run(boolean verbose)
            throws org.apache.hadoop.yarn.exceptions.YarnException,
                   IOException

Submit a request to the Hadoop YARN cluster's ResourceManager to obtain an application container. This will run our ApplicationMaster, which will in turn request app containers for Giraphs' master and all worker tasks.

Parameters:

verbose - Not implemented yet, to provide compatibility w/GiraphJob

Returns:

true if job is successful

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException