public class ValueAggregatorJob
extends java.lang.Object
Constructor and Description |
---|
ValueAggregatorJob() |
Modifier and Type | Method and Description |
---|---|
static JobConf |
createValueAggregatorJob(java.lang.String[] args)
Create an Aggregate based map/reduce job.
|
static JobConf |
createValueAggregatorJob(java.lang.String[] args,
java.lang.Class<?> caller)
Create an Aggregate based map/reduce job.
|
static JobConf |
createValueAggregatorJob(java.lang.String[] args,
java.lang.Class<? extends ValueAggregatorDescriptor>[] descriptors) |
static JobConf |
createValueAggregatorJob(java.lang.String[] args,
java.lang.Class<? extends ValueAggregatorDescriptor>[] descriptors,
java.lang.Class<?> caller) |
static JobControl |
createValueAggregatorJobs(java.lang.String[] args) |
static JobControl |
createValueAggregatorJobs(java.lang.String[] args,
java.lang.Class<? extends ValueAggregatorDescriptor>[] descriptors) |
static void |
main(java.lang.String[] args)
create and run an Aggregate based map/reduce job.
|
static void |
setAggregatorDescriptors(JobConf job,
java.lang.Class<? extends ValueAggregatorDescriptor>[] descriptors) |
public static JobControl createValueAggregatorJobs(java.lang.String[] args, java.lang.Class<? extends ValueAggregatorDescriptor>[] descriptors) throws java.io.IOException
java.io.IOException
public static JobControl createValueAggregatorJobs(java.lang.String[] args) throws java.io.IOException
java.io.IOException
public static JobConf createValueAggregatorJob(java.lang.String[] args) throws java.io.IOException
args
- the arguments used for job creation. Generic hadoop
arguments are accepted.java.io.IOException
GenericOptionsParser
public static JobConf createValueAggregatorJob(java.lang.String[] args, java.lang.Class<?> caller) throws java.io.IOException
args
- the arguments used for job creation. Generic hadoop
arguments are accepted.caller
- the the caller class.java.io.IOException
GenericOptionsParser
public static JobConf createValueAggregatorJob(java.lang.String[] args, java.lang.Class<? extends ValueAggregatorDescriptor>[] descriptors) throws java.io.IOException
java.io.IOException
public static JobConf createValueAggregatorJob(java.lang.String[] args, java.lang.Class<? extends ValueAggregatorDescriptor>[] descriptors, java.lang.Class<?> caller) throws java.io.IOException
java.io.IOException
public static void setAggregatorDescriptors(JobConf job, java.lang.Class<? extends ValueAggregatorDescriptor>[] descriptors)
public static void main(java.lang.String[] args) throws java.io.IOException
args
- the arguments used for job creationjava.io.IOException
Copyright © 2009 The Apache Software Foundation