A common method for launching the jobs according to the logical plan @param lp The logical plan @param jobName A String containing the job name to be used @return The PigStats object @throws ExecException @throws FrontendException
(LogicalPlan lp, String jobName)
| 1469 | * @throws FrontendException |
| 1470 | */ |
| 1471 | protected PigStats launchPlan(LogicalPlan lp, String jobName) throws ExecException, FrontendException { |
| 1472 | |
| 1473 | PigStats stats = null; |
| 1474 | try { |
| 1475 | stats = pigContext.getExecutionEngine().launchPig(lp, jobName, pigContext); |
| 1476 | } catch (ExecException e) { |
| 1477 | throw e; |
| 1478 | } catch (FrontendException e) { |
| 1479 | throw e; |
| 1480 | } catch (Exception e) { |
| 1481 | // There are a lot of exceptions thrown by the launcher. If this |
| 1482 | // is an ExecException, just let it through. Else wrap it. |
| 1483 | int errCode = 2043; |
| 1484 | String msg = "Unexpected error during execution."; |
| 1485 | throw new ExecException(msg, errCode, PigException.BUG, e); |
| 1486 | } |
| 1487 | |
| 1488 | return stats; |
| 1489 | } |
| 1490 | |
| 1491 | /** |
| 1492 | * NOTE: For testing only. Don't use. |
no test coverage detected