I
- Vertex idV
- Vertex dataE
- Edge datapublic 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
Object
type.Constructor and Description |
---|
GiraphYarnTask(org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptId)
Constructor.
|
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.
|
public GiraphYarnTask(org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptId)
taskAttemptId
- the MRv1 TaskAttemptID we constructed from CLI args
supplied by GiraphApplicationMaster.public void run()
public static void main(String[] args)
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
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.