public class HadoopUtils extends Object
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.
|
public static org.apache.hadoop.mapreduce.TaskAttemptContext makeTaskAttemptContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptID)
conf
- ConfigurationtaskAttemptID
- TaskAttemptID to usepublic static org.apache.hadoop.mapreduce.TaskAttemptContext makeTaskAttemptContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext)
conf
- ConfigurationtaskAttemptContext
- Use TaskAttemptID from this objectpublic static org.apache.hadoop.mapreduce.TaskAttemptContext makeTaskAttemptContext(org.apache.hadoop.conf.Configuration conf)
conf
- Configurationpublic static org.apache.hadoop.mapreduce.TaskAttemptContext makeTaskAttemptContext()
public static org.apache.hadoop.mapreduce.JobContext makeJobContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.JobID jobID)
conf
- ConfigurationjobID
- JobID to usepublic static org.apache.hadoop.mapreduce.JobID getJobID(org.apache.hadoop.mapreduce.Job job)
job
- submitted jobpublic static org.apache.hadoop.mapreduce.JobContext makeJobContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.JobContext jobContext)
conf
- ConfigurationjobContext
- Use JobID from this objectpublic static org.apache.hadoop.mapreduce.JobContext makeJobContext(org.apache.hadoop.conf.Configuration conf)
conf
- Configurationpublic static org.apache.hadoop.mapreduce.JobContext makeJobContext()
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.