Merge pull request #36 from gluster/BZ__createNonRecursive

Bz  create non recursive

Author: jayunit100

src/main/java/org/apache/hadoop/fs/glusterfs/GlusterFileSystem.java

@@ -569,7 +569,7 @@ public void setOwner(Path p, String username, String groupname) throws IOExcepti
 
       if (username == null) {
         execCommand(f, Shell.SET_GROUP_COMMAND, groupname); 
-      } 
+      }
       else {
         //OWNER[:[GROUP]]
         String s = username + (groupname == null? "": ":" + groupname);
@@ -592,4 +592,17 @@ public Path startLocalOutput(Path fsOutputFile,Path tmpLocalFile) throws IOExcep
     public void completeLocalOutput(Path fsOutputFile,Path tmpLocalFile) throws IOException{
         moveFromLocalFile(tmpLocalFile, fsOutputFile);
     }
+
+    /**
+     * Taken from https://github.com/quantcast/qfs/pull/21/files, a non
+     * recursive create implementation to support HBASE.
+     */
+    public FSDataOutputStream createNonRecursive(Path file,FsPermission permission,boolean overwrite,int bufferSize,short replication,long blockSize,Progressable progress) throws IOException{
+        Path parent=file.getParent();
+        if(parent==null||exists(parent)){
+            return create(file, permission, overwrite, bufferSize, replication, blockSize, progress);
+        }else{
+            throw new IOException("Parent "+parent+" does not exist");
+        }
+    }
 }

src/test/java/org/gluster/test/TestGluster.java

@@ -249,7 +249,7 @@ public void testPermissions() throws Exception{
         gfs.delete(new Path("aa"),true);
         assertFalse(gfs.exists(directory));
     }
-
+    
     @org.junit.Test
     public void testZDirs() throws Exception{
         final Path subDir1=new Path("td_dir.1");
@@ -435,4 +435,16 @@ public void test0aPermissions() throws Exception{
         gfs.delete(new Path("mnt"),true);
 
     }
+
+
+    @Test
+    public void testCreateNR() throws Exception{
+    	Path nonrec = new Path("nonrec");
+    	this.gfs.createNonRecursive(
+    			new Path("nonrec"),
+    			FsPermission.valueOf("-rwxrwxrwx"), 
+    			true, 100, (short)0, 0L, null);
+    	Assert.assertTrue(this.gfs.exists(new Path("nonrec")));
+    	this.gfs.delete(nonrec);
+    }
 }