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

Method storeEx

src/org/apache/pig/PigServer.java:1107–1125  ·  view source on GitHub ↗
(String alias, String filename, String func)

Source from the content-addressed store, hash-verified

1105 }
1106
1107 private PigStats storeEx(String alias, String filename, String func)
1108 throws IOException {
1109 if ("@".equals(alias)) {
1110 alias = getLastRel();
1111 }
1112 currDAG.parseQuery();
1113 currDAG.skipStores(); // skip the stores that have already been processed
1114 currDAG.buildPlan( alias );
1115
1116 try {
1117 QueryParserUtils.attachStorePlan(scope, currDAG.lp, filename, func, currDAG.getOperator( alias ), alias, pigContext);
1118 currDAG.compile();
1119 return executeCompiledLogicalPlan();
1120 } catch (PigException e) {
1121 int errCode = 1002;
1122 String msg = "Unable to store alias " + alias;
1123 throw new PigException(msg, errCode, PigException.INPUT, e);
1124 }
1125 }
1126
1127 /**
1128 * Provide information on how a pig query will be executed. For now

Callers 1

storeMethod · 0.95

Calls 9

getLastRelMethod · 0.95
attachStorePlanMethod · 0.95
parseQueryMethod · 0.80
skipStoresMethod · 0.80
equalsMethod · 0.45
buildPlanMethod · 0.45
getOperatorMethod · 0.45
compileMethod · 0.45

Tested by

no test coverage detected