public class TezLauncher extends Launcher
Launcher.HangingJobKiller, Launcher.JobControlThreadExceptionHandler
failureMap, jc, jobControlException, jobControlExceptionStackTrace, totalHadoopTimeSpent
Constructor and Description |
---|
TezLauncher() |
Modifier and Type | Method and Description |
---|---|
TezPlanContainer |
compile(PhysicalPlan php,
PigContext pc) |
void |
destroy() |
void |
explain(PhysicalPlan php,
PigContext pc,
PrintStream ps,
String format,
boolean verbose)
Explain how a pig job will be executed on the underlying infrastructure.
|
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.
|
static void |
processLoadAndParallelism(TezOperPlan tezPlan,
PigContext pc) |
calculateProgress, computeTimeSpent, getErrorMessages, getExceptionFromString, getStackTraceElement, getTotalHadoopTimeSpent, isComplete, reset, setJobException
public PigStats launchPig(PhysicalPlan php, String grpName, PigContext pc) throws Exception
Launcher
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 TezPlanContainer compile(PhysicalPlan php, PigContext pc) throws PlanException, IOException, VisitorException
PlanException
IOException
VisitorException
public static void processLoadAndParallelism(TezOperPlan tezPlan, PigContext pc) throws VisitorException
VisitorException
public void kill() throws BackendException
kill
in class Launcher
BackendException
public void killJob(String jobID, org.apache.hadoop.conf.Configuration conf) throws BackendException
killJob
in class Launcher
BackendException
Copyright © 2007-2017 The Apache Software Foundation