Permalink
Browse files

public parseVersion>

  • Loading branch information...
1 parent 80a80d0 commit d76c053af3f6c466803e5cde93497af07f3ff706 Sam Ritchie committed Sep 28, 2012
Showing with 3 additions and 3 deletions.
  1. +3 −3 src/jvm/backtype/hadoop/datastores/VersionedStore.java
@@ -25,7 +25,7 @@
public VersionedStore(String path) throws IOException {
this(Utils.getFS(path), path);
}
-
+
public VersionedStore(FileSystem fs, String path) throws IOException {
this.fs = fs;
root = path;
@@ -194,7 +194,7 @@ private long validateAndGetVersion(String path) {
return v;
}
- private Long parseVersion(String path) {
+ public Long parseVersion(String path) {
String name = new Path(path).getName();
if(name.endsWith(FINISHED_VERSION_SUFFIX)) {
name = name.substring(0, name.length()-FINISHED_VERSION_SUFFIX.length());
@@ -209,7 +209,7 @@ private Long parseVersion(String path) {
private void createNewFile(String path) throws IOException {
if(fs instanceof LocalFileSystem)
new File(path).createNewFile();
- else
+ else
fs.createNewFile(new Path(path));
}

0 comments on commit d76c053

Please sign in to comment.