()
| 249 | } |
| 250 | |
| 251 | @Test |
| 252 | public void testNonDfsLocation() throws Exception { |
| 253 | String nonDfsUrl = "har:///user/foo/f.har"; |
| 254 | String query = "a = load '" + nonDfsUrl + "' using PigStorage('\t','-noschema');" + |
| 255 | "store a into 'pigoutput';"; |
| 256 | LogicalPlan lp = Util.buildLp(servers[1], query); |
| 257 | LOLoad load = (LOLoad) lp.getSources().get(0); |
| 258 | nonDfsUrl = nonDfsUrl.replaceFirst("/$", ""); |
| 259 | assertEquals(nonDfsUrl, load.getFileSpec().getFileName()); |
| 260 | } |
| 261 | |
| 262 | @SuppressWarnings("unchecked") |
| 263 | private void testLoadingMultipleFiles(String[] inputFileNames, |
nothing calls this directly
no test coverage detected