(Path path)
| 1525 | } |
| 1526 | |
| 1527 | public static Path getFirstPartFile(Path path) throws Exception { |
| 1528 | FileStatus[] parts = FileSystem.get(path.toUri(), new Configuration()).listStatus(path, |
| 1529 | new PathFilter() { |
| 1530 | @Override |
| 1531 | public boolean accept(Path path) { |
| 1532 | return path.getName().startsWith("part-"); |
| 1533 | } |
| 1534 | }); |
| 1535 | return parts[0].getPath(); |
| 1536 | } |
| 1537 | |
| 1538 | public static File getFirstPartFile(File dir) throws Exception { |
| 1539 | File[] parts = dir.listFiles(new FilenameFilter() { |
no test coverage detected