public class ValueAggregatorJob extends Object
构造器和说明 |
---|
ValueAggregatorJob() |
限定符和类型 | 方法和说明 |
---|---|
static JobConf |
createValueAggregatorJob(String[] args)
Create an Aggregate based map/reduce job.
|
static JobConf |
createValueAggregatorJob(String[] args,
Class<?> caller)
Create an Aggregate based map/reduce job.
|
static JobConf |
createValueAggregatorJob(String[] args,
Class<? extends ValueAggregatorDescriptor>[] descriptors) |
static JobConf |
createValueAggregatorJob(String[] args,
Class<? extends ValueAggregatorDescriptor>[] descriptors,
Class<?> caller) |
static JobControl |
createValueAggregatorJobs(String[] args) |
static JobControl |
createValueAggregatorJobs(String[] args,
Class<? extends ValueAggregatorDescriptor>[] descriptors) |
static void |
main(String[] args)
create and run an Aggregate based map/reduce job.
|
static void |
setAggregatorDescriptors(JobConf job,
Class<? extends ValueAggregatorDescriptor>[] descriptors) |
public static JobControl createValueAggregatorJobs(String[] args, Class<? extends ValueAggregatorDescriptor>[] descriptors) throws IOException
IOException
public static JobControl createValueAggregatorJobs(String[] args) throws IOException
IOException
public static JobConf createValueAggregatorJob(String[] args) throws IOException
args
- the arguments used for job creation. Generic hadoop
arguments are accepted.IOException
GenericOptionsParser
public static JobConf createValueAggregatorJob(String[] args, Class<?> caller) throws IOException
args
- the arguments used for job creation. Generic hadoop
arguments are accepted.caller
- the the caller class.IOException
GenericOptionsParser
public static JobConf createValueAggregatorJob(String[] args, Class<? extends ValueAggregatorDescriptor>[] descriptors) throws IOException
IOException
public static JobConf createValueAggregatorJob(String[] args, Class<? extends ValueAggregatorDescriptor>[] descriptors, Class<?> caller) throws IOException
IOException
public static void setAggregatorDescriptors(JobConf job, Class<? extends ValueAggregatorDescriptor>[] descriptors)
public static void main(String[] args) throws IOException
args
- the arguments used for job creationIOException
Copyright © 2009 The Apache Software Foundation