()
| 46 | } |
| 47 | |
| 48 | @Test |
| 49 | public void testSingleStore() throws Exception{ |
| 50 | pig.registerQuery("A = load " + fileName + ";"); |
| 51 | |
| 52 | pig.store("A", tmpFile1); |
| 53 | |
| 54 | pig.registerQuery("B = load " + tmpFile1 + ";"); |
| 55 | Iterator<Tuple> iter = pig.openIterator("B"); |
| 56 | |
| 57 | int i =0; |
| 58 | while (iter.hasNext()){ |
| 59 | Tuple t = iter.next(); |
| 60 | assertEquals(DataType.toInteger(t.get(0)).intValue(),i); |
| 61 | assertEquals(DataType.toInteger(t.get(1)).intValue(),i); |
| 62 | i++; |
| 63 | } |
| 64 | } |
| 65 | |
| 66 | @Test |
| 67 | public void testMultipleStore() throws Exception{ |
nothing calls this directly
no test coverage detected