()
| 106 | } |
| 107 | |
| 108 | @Before |
| 109 | public void setUp() throws Exception { |
| 110 | File f = File.createTempFile("tmp", ""); |
| 111 | PrintWriter pw = new PrintWriter(f); |
| 112 | for (int i=0;i<LOOP_COUNT; i++){ |
| 113 | pw.println(i + "\t" + i); |
| 114 | } |
| 115 | pw.close(); |
| 116 | pig = new PigServer(cluster.getExecType(), cluster.getProperties()); |
| 117 | fileName = "'" + FileLocalizer.hadoopify(f.toString(), pig.getPigContext()) + "'"; |
| 118 | tmpFile1 = "'" + FileLocalizer.getTemporaryPath(pig.getPigContext()).toString() + "'"; |
| 119 | tmpFile2 = "'" + FileLocalizer.getTemporaryPath(pig.getPigContext()).toString() + "'"; |
| 120 | f.delete(); |
| 121 | } |
| 122 | |
| 123 | } |
nothing calls this directly
no test coverage detected