(LogicalPlan plan)
| 228 | } |
| 229 | |
| 230 | PhysicalPlan compilePlan(LogicalPlan plan) throws ExecException, FrontendException { |
| 231 | newPlan = new LogicalPlan(plan); |
| 232 | plan.optimize(pigContext); |
| 233 | PhysicalPlan result = execEngine.compile(plan, null); |
| 234 | return result; |
| 235 | } |
| 236 | |
| 237 | public Map<Operator, DataBag> getData() throws IOException, InterruptedException { |
| 238 | return getData(physPlan); |
no test coverage detected