public class $MapReduce
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool
| Constructor and Description |
|---|
$MapReduce() |
| Modifier and Type | Method and Description |
|---|---|
$Hdfs |
getHdfs() |
org.apache.hadoop.mapreduce.Job |
getJob() |
$MapReduceConfiguration |
getMapReduceConfiguration() |
$MapReduce |
init($Hdfs hdfs,
$MapReduceConfiguration mapReduceConfiguration) |
int |
run(String[] args) |
boolean |
runJob() |
$MapReduce |
setHdfs($Hdfs hdfs) |
$MapReduce |
setJob(org.apache.hadoop.mapreduce.Job job) |
$MapReduce |
setMapReduceConfiguration($MapReduceConfiguration mapReduceConfiguration) |
void |
toolRun(String[] args) |
public $MapReduce init($Hdfs hdfs, $MapReduceConfiguration mapReduceConfiguration) throws Exception
Exceptionpublic int run(String[] args) throws Exception
run in interface org.apache.hadoop.util.ToolExceptionpublic boolean runJob()
throws InterruptedException,
IOException,
ClassNotFoundException
public $Hdfs getHdfs()
public $MapReduce setHdfs($Hdfs hdfs)
public org.apache.hadoop.mapreduce.Job getJob()
public $MapReduce setJob(org.apache.hadoop.mapreduce.Job job)
public $MapReduceConfiguration getMapReduceConfiguration()
public $MapReduce setMapReduceConfiguration($MapReduceConfiguration mapReduceConfiguration)
Copyright © 2021. All rights reserved.