MCPcopy Create free account
hub / github.com/apache/pig / execute

Method execute

src/org/apache/pig/PigServer.java:1432–1452  ·  view source on GitHub ↗

Compile and execute the current plan. @return @throws IOException

()

Source from the content-addressed store, hash-verified

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 {

Callers 3

executeBatchMethod · 0.95
getExamplesMethod · 0.95
registerQueryMethod · 0.45

Calls 8

getMethod · 0.95
countExecutedStoresMethod · 0.80
setPropertyMethod · 0.65
sizeMethod · 0.65
getPropertiesMethod · 0.45
compileMethod · 0.45
getSignatureMethod · 0.45

Tested by

no test coverage detected