Skip to content
Browse files

add constructor to versionedstore.

  • Loading branch information...
1 parent 4897e9c commit ff74fdd6210298572154c2866593b3bf46d06f2f Sam Ritchie committed Sep 27, 2012
Showing with 7 additions and 1 deletion.
  1. +1 −1 project.clj
  2. +6 −0 src/jvm/backtype/hadoop/datastores/VersionedStore.java
View
2 project.clj
@@ -1,4 +1,4 @@
-(defproject backtype/dfs-datastores "1.2.1-SNAPSHOT"
+(defproject backtype/dfs-datastores "1.2.0"
:min-lein-version "2.0.0"
:description "Dead-simple vertical partitioning, compression, appends, and consolidation of data on a distributed filesystem."
:url "https://github.com/nathanmarz/dfs-datastores"
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 ff74fdd

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