@@ -592,21 +592,17 @@ public Path startLocalOutput(Path fsOutputFile,Path tmpLocalFile) throws IOExcep
592
592
public void completeLocalOutput (Path fsOutputFile ,Path tmpLocalFile ) throws IOException {
593
593
moveFromLocalFile (tmpLocalFile , fsOutputFile );
594
594
}
595
-
595
+
596
596
/**
597
- * Taken from https://github.com/quantcast/qfs/pull/21/files, a non recursive create implementation
598
- * to support HBASE.
597
+ * Taken from https://github.com/quantcast/qfs/pull/21/files, a non
598
+ * recursive create implementation to support HBASE.
599
599
*/
600
- public FSDataOutputStream createNonRecursive (Path file ,
601
- FsPermission permission , boolean overwrite , int bufferSize ,
602
- short replication , long blockSize , Progressable progress )
603
- throws IOException {
604
- Path parent = file .getParent ();
605
- if (parent == null || exists (parent )) {
606
- return create (file , permission , overwrite , bufferSize , replication ,
607
- blockSize , progress );
608
- } else {
609
- throw new IOException ("Parent " + parent + " does not exist" );
610
- }
611
- }
600
+ public FSDataOutputStream createNonRecursive (Path file ,FsPermission permission ,boolean overwrite ,int bufferSize ,short replication ,long blockSize ,Progressable progress ) throws IOException {
601
+ Path parent =file .getParent ();
602
+ if (parent ==null ||exists (parent )){
603
+ return create (file , permission , overwrite , bufferSize , replication , blockSize , progress );
604
+ }else {
605
+ throw new IOException ("Parent " +parent +" does not exist" );
606
+ }
607
+ }
612
608
}
0 commit comments