Compile and execute the current plan. @return @throws IOException
()
| 1430 | * @throws IOException |
| 1431 | */ |
| 1432 | private PigStats execute() throws IOException { |
| 1433 | pigContext.getProperties().setProperty( PigContext.JOB_NAME, jobName ); |
| 1434 | if( jobPriority != null ) { |
| 1435 | pigContext.getProperties().setProperty( PigContext.JOB_PRIORITY, jobPriority ); |
| 1436 | } |
| 1437 | |
| 1438 | // In this plan, all stores in the plan will be executed. They should be ignored if the plan is reused. |
| 1439 | currDAG.countExecutedStores(); |
| 1440 | |
| 1441 | currDAG.compile(); |
| 1442 | |
| 1443 | if( currDAG.lp.size() == 0 ) { |
| 1444 | return PigStats.get(); |
| 1445 | } |
| 1446 | |
| 1447 | pigContext.getProperties().setProperty("pig.logical.plan.signature", currDAG.lp.getSignature()); |
| 1448 | |
| 1449 | PigStats stats = executeCompiledLogicalPlan(); |
| 1450 | |
| 1451 | return stats; |
| 1452 | } |
| 1453 | |
| 1454 | private PigStats executeCompiledLogicalPlan() throws ExecException, |
| 1455 | FrontendException { |
no test coverage detected