Given a (modified) new logical plan, run the script. @param newPlan plan to run @param jobName name to give the MR jobs associated with this run @return list of exec jobs describing the jobs that were run. @throws FrontendException if plan translation fails. @throws ExecException if running the job
(LogicalPlan newPlan,
String jobName)
| 147 | * @throws ExecException if running the job fails. |
| 148 | */ |
| 149 | public List<ExecJob> runPlan(LogicalPlan newPlan, |
| 150 | String jobName) throws FrontendException, ExecException { |
| 151 | PigStats stats = launchPlan(newPlan, jobName); |
| 152 | return getJobs(stats); |
| 153 | } |
| 154 | |
| 155 | public static class PigPlans { |
| 156 |