@InterfaceAudience.Public @InterfaceStability.Stable public class ValueAggregatorJob extends Object
Constructor and Description |
---|
ValueAggregatorJob() |
Modifier and Type | Method and Description |
---|---|
static Job |
createValueAggregatorJob(Configuration conf,
String[] args)
Create an Aggregate based map/reduce job.
|
static Job |
createValueAggregatorJob(String[] args,
Class<? extends ValueAggregatorDescriptor>[] descriptors) |
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 Configuration |
setAggregatorDescriptors(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 Job createValueAggregatorJob(Configuration conf, String[] args) throws IOException
conf
- The configuration for jobargs
- the arguments used for job creation. Generic hadoop
arguments are accepted.IOException
GenericOptionsParser
public static Job createValueAggregatorJob(String[] args, Class<? extends ValueAggregatorDescriptor>[] descriptors) throws IOException
IOException
public static Configuration setAggregatorDescriptors(Class<? extends ValueAggregatorDescriptor>[] descriptors)
public static void main(String[] args) throws IOException, InterruptedException, ClassNotFoundException
args
- the arguments used for job creationIOException
InterruptedException
ClassNotFoundException
Copyright © 2021 Apache Software Foundation. All rights reserved.