org.apache.giraph.yarn

Class GiraphYarnTask<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.yarn.GiraphYarnTask<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex data

E - Edge data

public class GiraphYarnTask<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object

This process will execute the BSP graph tasks alloted to this YARN execution container. All tasks will be performed by calling the GraphTaskManager object. Since this GiraphYarnTask will not be passing data by key-value pairs through the MR framework, the Mapper parameter types are irrelevant, and set to Object type.

Constructor Summary

Constructors

Constructor and Description
GiraphYarnTask(org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptId) Constructor.

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args) Task entry point.
void	run() Run one Giraph worker (or master) task, hosted in this execution container.

Methods inherited from class java.lang.Object

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

Constructor Detail

GiraphYarnTask

public GiraphYarnTask(org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptId)

Constructor. Build our DUMMY MRv1 data structures to pass to our GiraphTaskManager. This allows us to continue to look the other way while Giraph relies on MRv1 under the hood.

Parameters:

taskAttemptId - the MRv1 TaskAttemptID we constructed from CLI args supplied by GiraphApplicationMaster.

Method Detail

run

public void run()

Run one Giraph worker (or master) task, hosted in this execution container.

main

public static void main(String[] args)

Task entry point.

Parameters:

args - CLI arguments injected by GiraphApplicationMaster to hand off job, task, and attempt ID's to this (and every) Giraph task. Args should be: AppId ContainerId AppAttemptId