org.apache.giraph.job

Class HadoopUtils

java.lang.Object

org.apache.giraph.job.HadoopUtils

public class HadoopUtils
extends Object

Helpers for dealing with Hadoop.

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.mapreduce.JobID	getJobID(org.apache.hadoop.mapreduce.Job job) Get Job ID from job.
static org.apache.hadoop.mapreduce.JobContext	makeJobContext() Create a JobContext, supporting many Hadoops.
static org.apache.hadoop.mapreduce.JobContext	makeJobContext(org.apache.hadoop.conf.Configuration conf) Create a JobContext, supporting many Hadoops.
static org.apache.hadoop.mapreduce.JobContext	makeJobContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.JobContext jobContext) Create a JobContext, supporting many Hadoops.
static org.apache.hadoop.mapreduce.JobContext	makeJobContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.JobID jobID) Create a JobContext, supporting many Hadoops.
static org.apache.hadoop.mapreduce.TaskAttemptContext	makeTaskAttemptContext() Create a TaskAttemptContext, supporting many Hadoops.
static org.apache.hadoop.mapreduce.TaskAttemptContext	makeTaskAttemptContext(org.apache.hadoop.conf.Configuration conf) Create a TaskAttemptContext, supporting many Hadoops.
static org.apache.hadoop.mapreduce.TaskAttemptContext	makeTaskAttemptContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) Create a TaskAttemptContext, supporting many Hadoops.
static org.apache.hadoop.mapreduce.TaskAttemptContext	makeTaskAttemptContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptID) Create a TaskAttemptContext, supporting many Hadoops.

Methods inherited from class java.lang.Object

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

Method Detail

makeTaskAttemptContext

public static org.apache.hadoop.mapreduce.TaskAttemptContext makeTaskAttemptContext(org.apache.hadoop.conf.Configuration conf,
                                                                                    org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptID)

Create a TaskAttemptContext, supporting many Hadoops.

Parameters:

conf - Configuration

taskAttemptID - TaskAttemptID to use

Returns:

TaskAttemptContext

makeTaskAttemptContext

public static org.apache.hadoop.mapreduce.TaskAttemptContext makeTaskAttemptContext(org.apache.hadoop.conf.Configuration conf,
                                                                                    org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext)

Create a TaskAttemptContext, supporting many Hadoops.

Parameters:

conf - Configuration

taskAttemptContext - Use TaskAttemptID from this object

Returns:

TaskAttemptContext

makeTaskAttemptContext

public static org.apache.hadoop.mapreduce.TaskAttemptContext makeTaskAttemptContext(org.apache.hadoop.conf.Configuration conf)

Create a TaskAttemptContext, supporting many Hadoops.

Parameters:

conf - Configuration

Returns:

TaskAttemptContext

makeTaskAttemptContext

public static org.apache.hadoop.mapreduce.TaskAttemptContext makeTaskAttemptContext()

Create a TaskAttemptContext, supporting many Hadoops.

Returns:

TaskAttemptContext

makeJobContext

public static org.apache.hadoop.mapreduce.JobContext makeJobContext(org.apache.hadoop.conf.Configuration conf,
                                                                    org.apache.hadoop.mapreduce.JobID jobID)

Create a JobContext, supporting many Hadoops.

Parameters:

conf - Configuration

jobID - JobID to use

Returns:

JobContext

getJobID

public static org.apache.hadoop.mapreduce.JobID getJobID(org.apache.hadoop.mapreduce.Job job)

Get Job ID from job. May return null for hadoop 0.20.203

Parameters:

job - submitted job

Returns:

JobId for submitted job.

makeJobContext

public static org.apache.hadoop.mapreduce.JobContext makeJobContext(org.apache.hadoop.conf.Configuration conf,
                                                                    org.apache.hadoop.mapreduce.JobContext jobContext)

Create a JobContext, supporting many Hadoops.

Parameters:

conf - Configuration

jobContext - Use JobID from this object

Returns:

JobContext

makeJobContext

public static org.apache.hadoop.mapreduce.JobContext makeJobContext(org.apache.hadoop.conf.Configuration conf)

Create a JobContext, supporting many Hadoops.

Parameters:

conf - Configuration

Returns:

JobContext

makeJobContext

public static org.apache.hadoop.mapreduce.JobContext makeJobContext()

Create a JobContext, supporting many Hadoops.

Returns:

JobContext