@Test(enabled = false) public void testMakeDirsWithPermission() throws IOException, URISyntaxException { HDFSRoot hdfsRoot = new HDFSRoot("/tmp/mkdirsWithPermission"); MetricsFileSystemInstrumentation fs = (MetricsFileSystemInstrumentation) FileSystem.get(new URI(instrumentedURI), new Configuration()); Path newDir = new Path (hdfsRoot.getRootPath(), new Path("X/Y/Z")); fs.mkdirs(newDir, new FsPermission(FsAction.ALL, FsAction.ALL, FsAction.READ)); Assert.assertEquals(fs.mkdirTimer.getCount(), 1); hdfsRoot.cleanupRoot(); }
public boolean mkdirs(Path f, FsPermission permission) throws IOException { try (Closeable context = new TimerContextWithLog(mkdirTimer.time(), "mkdirs", f, permission)) { return super.mkdirs (f, permission); } }
MetricsFileSystemInstrumentation extends FileSystemInstrumentation { public boolean mkdirs(Path f, FsPermission permission) throws IOException { try (Closeable context = new TimerContextWithLog(mkdirTimer.time(), "mkdirs", f, permission)) { return super.mkdirs (f, permission); } } }
MetricsFileSystemInstrumentation extends FileSystemInstrumentation { public boolean mkdirs(Path f, FsPermission permission) throws IOException { try (Closeable context = new TimerContextWithLog(mkdirTimer.time(), "mkdirs", f, permission)) { return super.mkdirs (f, permission); } } MetricsFileSystemInstrumentation(FileSystem underlying); }
MetricsFileSystemInstrumentation extends FileSystemInstrumentation { public boolean mkdirs(Path f, FsPermission permission) throws IOException { try (Closeable context = new TimerContextWithLog(mkdirTimer.time(), "mkdirs", f, permission)) { return super.mkdirs (f, permission); } } MetricsFileSystemInstrumentation(FileSystem underlying); @Override void close(); boolean mkdirs(Path f, FsPermission permission); boolean rename(Path src, Path dst); boolean delete(Path f, boolean recursive); FileStatus[] listStatus(Path path); FileStatus[] globStatus(Path pathPattern); FileStatus[] globStatus(Path pathPattern, PathFilter filter); RemoteIterator<LocatedFileStatus> listFiles(Path f, boolean recursive); FSDataOutputStream create(Path f,
    FsPermission permission,
    boolean overwrite,
    int bufferSize,
    short replication,
    long blockSize,
    Progressable progress); FSDataInputStream open(Path f, int bufferSize); void setOwner(Path f, String user, String group); FileStatus getFileStatus(Path f); void setPermission(Path f, final FsPermission permission); void setTimes(Path f, long t, long a); FSDataOutputStream append(Path p, final int bufferSize, Progressable progress); void concat(Path trg, Path [] psrcs); }
MetricsFileSystemInstrumentation extends FileSystemInstrumentation { public boolean mkdirs(Path f, FsPermission permission) throws IOException { try (Closeable context = new TimerContextWithLog(mkdirTimer.time(), "mkdirs", f, permission)) { return super.mkdirs (f, permission); } } MetricsFileSystemInstrumentation(FileSystem underlying); @Override void close(); boolean mkdirs(Path f, FsPermission permission); boolean rename(Path src, Path dst); boolean delete(Path f, boolean recursive); FileStatus[] listStatus(Path path); FileStatus[] globStatus(Path pathPattern); FileStatus[] globStatus(Path pathPattern, PathFilter filter); RemoteIterator<LocatedFileStatus> listFiles(Path f, boolean recursive); FSDataOutputStream create(Path f,
    FsPermission permission,
    boolean overwrite,
    int bufferSize,
    short replication,
    long blockSize,
    Progressable progress); FSDataInputStream open(Path f, int bufferSize); void setOwner(Path f, String user, String group); FileStatus getFileStatus(Path f); void setPermission(Path f, final FsPermission permission); void setTimes(Path f, long t, long a); FSDataOutputStream append(Path p, final int bufferSize, Progressable progress); void concat(Path trg, Path [] psrcs);  }