@InterfaceAudience.Public @InterfaceStability.Stable public class ValueAggregatorJob extends Object
Constructor and Description |
---|
ValueAggregatorJob() |
Modifier and Type | Method and Description |
---|---|
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 ValueAggregatorJob()
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, 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) throws IOException
args
- the arguments used for job creation. Generic hadoop
arguments are accepted.IOException
GenericOptionsParser
public static JobConf createValueAggregatorJob(String[] args, Class<? extends ValueAggregatorDescriptor>[] descriptors) throws IOException
IOException
public static void setAggregatorDescriptors(JobConf job, Class<? extends ValueAggregatorDescriptor>[] descriptors)
public static JobConf createValueAggregatorJob(String[] args, Class<? extends ValueAggregatorDescriptor>[] descriptors, Class<?> caller) throws IOException
IOException
public static void main(String[] args) throws IOException
args
- the arguments used for job creationIOException
Copyright © 2015 Apache Software Foundation. All rights reserved.