Paths { public static Path getMultipartUploadCommitsDirectory(Configuration conf, String uuid) throws IOException { return getMultipartUploadCommitsDirectory(FileSystem.get(conf), conf, uuid); } private  Paths(); static String addUUID(String pathStr, String uuid); static String getParent(String pathStr); static String getRelativePath(Path basePath,
      Path fullPath); static Path path(Path parent, String... child); static Path getLocalTaskAttemptTempDir(final Configuration conf,
      final String uuid,
      final TaskAttemptID attemptID); static void clearTempFolderInfo(final TaskAttemptID attemptID); @VisibleForTesting static void resetTempFolderCache(); static Path tempDirForStaging(FileSystem fs,
      Configuration conf); static Path getMultipartUploadCommitsDirectory(Configuration conf,
      String uuid); static Set<String> getPartitions(Path attemptPath,
      List<? extends FileStatus> taskOutput);  }
@Test public void testMPUCommitDir() throws Throwable { Configuration conf = new Configuration(); LocalFileSystem localFS = FileSystem.getLocal(conf); Path dir = getMultipartUploadCommitsDirectory(localFS, conf, "UUID"); assertTrue(dir.toString().endsWith("UUID/" + StagingCommitterConstants.STAGING_UPLOADS)); }