()
| 75 | } |
| 76 | |
| 77 | @Test |
| 78 | public void testUDFReturnMap_LocalMode() throws Exception { |
| 79 | PigServer pig = new PigServer(Util.getLocalTestMode()); |
| 80 | pig.registerScript(TempScriptFile.getAbsolutePath()); |
| 81 | |
| 82 | Iterator<Tuple> iterator = pig.openIterator("B"); |
| 83 | while (iterator.hasNext()) { |
| 84 | Tuple tuple = iterator.next(); |
| 85 | @SuppressWarnings("unchecked") |
| 86 | Map<Object, Object> result = (Map<Object, Object>) tuple.get(0); |
| 87 | assertEquals(result, MyUDFReturnMap.map); |
| 88 | } |
| 89 | } |
| 90 | |
| 91 | @Test |
| 92 | public void testUDFReturnMap_MapReduceMode() throws Exception { |
nothing calls this directly
no test coverage detected