()
| 387 | } |
| 388 | |
| 389 | private void setupEvalFuncMap() { |
| 390 | for (String[] aggGroup : aggs) { |
| 391 | for (String agg : aggGroup) { |
| 392 | // doing this as a two step process because PigContext.instantiateFuncFromSpec("SUM.Intermediate") |
| 393 | // fails with class resolution error. |
| 394 | EvalFunc<?> func = (EvalFunc<?>)PigContext.instantiateFuncFromSpec(agg); |
| 395 | evalFuncMap.put(agg, func); |
| 396 | evalFuncMap.put(agg + "Initial", (EvalFunc<?>)PigContext.instantiateFuncFromSpec(((Algebraic)func).getInitial())); |
| 397 | evalFuncMap.put(agg + "Intermediate", (EvalFunc<?>)PigContext.instantiateFuncFromSpec(((Algebraic)func).getIntermed())); |
| 398 | evalFuncMap.put(agg + "Final", (EvalFunc<?>)PigContext.instantiateFuncFromSpec(((Algebraic)func).getFinal())); |
| 399 | } |
| 400 | } |
| 401 | } |
| 402 | |
| 403 | @Test |
| 404 | public void testAddSubtractDuration() throws Exception { |
no test coverage detected