Skip to content
Browse files

Merge branch 'develop'

  • Loading branch information...
2 parents 0e3888d + ff74fdd commit 80a80d0943b6db630bfd411fa9fbabcb49d04b72 Sam Ritchie committed
Showing with 6 additions and 0 deletions.
  1. +6 −0 src/jvm/backtype/hadoop/datastores/VersionedStore.java
View
6 src/jvm/backtype/hadoop/datastores/VersionedStore.java
@@ -1,6 +1,7 @@
package backtype.hadoop.datastores;
import backtype.support.Utils;
+import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocalFileSystem;
@@ -31,6 +32,11 @@ public VersionedStore(FileSystem fs, String path) throws IOException {
mkdirs(root);
}
+ public VersionedStore(Path path, Configuration conf) throws IOException {
+ this.fs = path.getFileSystem(conf);
+ this.root = path.toString();
+ }
+
public FileSystem getFileSystem() {
return fs;
}

0 comments on commit 80a80d0

Please sign in to comment.
Something went wrong with that request. Please try again.