@Test public void testMkdir() { try { hdfsClient.mkdir("/tmp/test-001/2/3/"); assertEquals(hdfsClient.exists("/tmp/test-001/2/3/"), true); } catch (IOException e) { assertTrue(false); } hdfsClient.delete("/tmp/test-001", true); try { assertEquals(hdfsClient.exists("/tmp/test-001"), false); } catch (IOException e) { assertTrue(true); } }
public void mkdir(String dir) throws HdfsException { mkdir(dir, FsPermission.getDefault()); }
HdfsClient implements Closeable { public void mkdir(String dir) throws HdfsException { mkdir(dir, FsPermission.getDefault()); } }
HdfsClient implements Closeable { public void mkdir(String dir) throws HdfsException { mkdir(dir, FsPermission.getDefault()); } private  HdfsClient(Configuration conf); }
HdfsClient implements Closeable { public void mkdir(String dir) throws HdfsException { mkdir(dir, FsPermission.getDefault()); } private  HdfsClient(Configuration conf); static void init(Configuration conf); static HdfsClient getInstance(); void addFile(String fileName, byte[] content, String destPath, boolean isOverwrite); void readFile(String hdfsFile, String localFile, boolean overwrite); byte[] readFile(String hdfsFile); boolean delete(String path, boolean recursive); boolean rename(String path, String destPath); void mkdir(String dir); void mkdir(String dir, FsPermission perm); void setOwner(Path path, String user, String group); void setPermission(Path path, FsPermission perm); void setPermissionThis(Path path, FsPermission perm); boolean copy(String srcPath, String dstPath, boolean deleteSource, boolean overwrite); boolean copyLocalToHdfs(String srcPath, String dstPath, boolean deleteSource, boolean overwrite); boolean copyHdfsToLocal(String srcPath, String dstPath, boolean deleteSource, boolean overwrite); long getFileLength(String filePath); boolean exists(String filePath); FileStatus getFileStatus(String filePath); FileStatus[] listFileStatus(String filePath); ContentSummary getContentSummary(String filePath); String getUrl(); @Override void close(); FsStatus getCapacity(); }
HdfsClient implements Closeable { public void mkdir(String dir) throws HdfsException { mkdir(dir, FsPermission.getDefault()); } private  HdfsClient(Configuration conf); static void init(Configuration conf); static HdfsClient getInstance(); void addFile(String fileName, byte[] content, String destPath, boolean isOverwrite); void readFile(String hdfsFile, String localFile, boolean overwrite); byte[] readFile(String hdfsFile); boolean delete(String path, boolean recursive); boolean rename(String path, String destPath); void mkdir(String dir); void mkdir(String dir, FsPermission perm); void setOwner(Path path, String user, String group); void setPermission(Path path, FsPermission perm); void setPermissionThis(Path path, FsPermission perm); boolean copy(String srcPath, String dstPath, boolean deleteSource, boolean overwrite); boolean copyLocalToHdfs(String srcPath, String dstPath, boolean deleteSource, boolean overwrite); boolean copyHdfsToLocal(String srcPath, String dstPath, boolean deleteSource, boolean overwrite); long getFileLength(String filePath); boolean exists(String filePath); FileStatus getFileStatus(String filePath); FileStatus[] listFileStatus(String filePath); ContentSummary getContentSummary(String filePath); String getUrl(); @Override void close(); FsStatus getCapacity();  }