public class MapReduceJobController extends Object implements MapReduceJobRunner, IndependentJobRunner
MapReduceJobController.PostOperationTask
to allow job definitions to
perform an action after running. The purpose of this added task is to support information from a
prior job in the sequence(such as temporary file names, job IDs, stats) to be provided to the
next job or set of jobs.Modifier and Type | Class and Description |
---|---|
static interface |
MapReduceJobController.PostOperationTask |
Modifier and Type | Field and Description |
---|---|
static MapReduceJobController.PostOperationTask |
DoNothingTask |
Constructor and Description |
---|
MapReduceJobController() |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.conf.Configuration |
getConfiguration(PropertyManagement pm) |
Collection<ParameterEnum<?>> |
getParameters() |
MapReduceJobRunner[] |
getRunners() |
protected void |
init(MapReduceJobRunner[] runners,
MapReduceJobController.PostOperationTask[] runSetUpTasks) |
int |
run(org.apache.hadoop.conf.Configuration config,
PropertyManagement runTimeProperties) |
int |
run(PropertyManagement runTimeProperties) |
public static final MapReduceJobController.PostOperationTask DoNothingTask
protected void init(MapReduceJobRunner[] runners, MapReduceJobController.PostOperationTask[] runSetUpTasks)
public MapReduceJobRunner[] getRunners()
public int run(org.apache.hadoop.conf.Configuration config, PropertyManagement runTimeProperties) throws Exception
run
in interface MapReduceJobRunner
Exception
public Collection<ParameterEnum<?>> getParameters()
getParameters
in interface IndependentJobRunner
public int run(PropertyManagement runTimeProperties) throws Exception
run
in interface IndependentJobRunner
Exception
public static org.apache.hadoop.conf.Configuration getConfiguration(PropertyManagement pm) throws IOException
IOException
Copyright © 2013–2022. All rights reserved.