public class MapReduceLauncher extends Launcher
Launcher.HangingJobKiller, Launcher.JobControlThreadExceptionHandler
Modifier and Type | Field and Description |
---|---|
static String |
SUCCEEDED_FILE_NAME |
failureMap, jc, jobControlException, jobControlExceptionStackTrace, totalHadoopTimeSpent
Constructor and Description |
---|
MapReduceLauncher() |
Modifier and Type | Method and Description |
---|---|
MROperPlan |
compile(PhysicalPlan php,
PigContext pc) |
void |
explain(PhysicalPlan php,
PigContext pc,
PrintStream ps,
String format,
boolean verbose)
Explain how a pig job will be executed on the underlying infrastructure.
|
Exception |
getError(FileSpec spec)
Get the exception that caused a failure on the backend for a
store location (if any).
|
void |
kill() |
void |
killJob(String jobID,
org.apache.hadoop.conf.Configuration conf) |
PigStats |
launchPig(PhysicalPlan php,
String grpName,
PigContext pc)
Method to launch pig for hadoop either for a cluster's job tracker or for
a local job runner.
|
calculateProgress, computeTimeSpent, destroy, getErrorMessages, getExceptionFromString, getStackTraceElement, getTotalHadoopTimeSpent, isComplete, reset, setJobException
public static final String SUCCEEDED_FILE_NAME
public void killJob(String jobID, org.apache.hadoop.conf.Configuration conf) throws BackendException
killJob
in class Launcher
BackendException
public Exception getError(FileSpec spec)
public PigStats launchPig(PhysicalPlan php, String grpName, PigContext pc) throws PlanException, VisitorException, IOException, ExecException, JobCreationException, Exception
Launcher
launchPig
in class Launcher
Exception
PlanException
VisitorException
IOException
ExecException
JobCreationException
public void explain(PhysicalPlan php, PigContext pc, PrintStream ps, String format, boolean verbose) throws PlanException, VisitorException, IOException
Launcher
explain
in class Launcher
php
- PhysicalPlan to explainpc
- PigContext to use for configurationps
- PrintStream to write output on.format
- Format to write inverbose
- Amount of information to printVisitorException
IOException
PlanException
public MROperPlan compile(PhysicalPlan php, PigContext pc) throws PlanException, IOException, VisitorException
PlanException
IOException
VisitorException
Copyright © 2007-2017 The Apache Software Foundation