(String alias, String filename, String func)
| 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 |
no test coverage detected