(PigContext pigContext)
| 88 | } |
| 89 | |
| 90 | static Path getCurrentDir(PigContext pigContext) throws IOException { |
| 91 | DataStorage dfs = pigContext.getDfs(); |
| 92 | ContainerDescriptor desc = dfs.getActiveContainer(); |
| 93 | ElementDescriptor el = dfs.asElement(desc); |
| 94 | return new Path(el.toString()); |
| 95 | } |
| 96 | |
| 97 | static void setHdfsServers(String absolutePath, PigContext pigContext) throws URISyntaxException { |
| 98 | // First check for the file system via the new property |
no test coverage detected