backtype.storm.utils
Class VersionedStore
java.lang.Object
backtype.storm.utils.VersionedStore
public class VersionedStore
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
VersionedStore
public VersionedStore(java.lang.String path)
throws java.io.IOException
- Throws:
java.io.IOException
getRoot
public java.lang.String getRoot()
versionPath
public java.lang.String versionPath(long version)
mostRecentVersionPath
public java.lang.String mostRecentVersionPath()
throws java.io.IOException
- Throws:
java.io.IOException
mostRecentVersionPath
public java.lang.String mostRecentVersionPath(long maxVersion)
throws java.io.IOException
- Throws:
java.io.IOException
mostRecentVersion
public java.lang.Long mostRecentVersion()
throws java.io.IOException
- Throws:
java.io.IOException
mostRecentVersion
public java.lang.Long mostRecentVersion(long maxVersion)
throws java.io.IOException
- Throws:
java.io.IOException
createVersion
public java.lang.String createVersion()
throws java.io.IOException
- Throws:
java.io.IOException
createVersion
public java.lang.String createVersion(long version)
throws java.io.IOException
- Throws:
java.io.IOException
failVersion
public void failVersion(java.lang.String path)
throws java.io.IOException
- Throws:
java.io.IOException
deleteVersion
public void deleteVersion(long version)
throws java.io.IOException
- Throws:
java.io.IOException
succeedVersion
public void succeedVersion(java.lang.String path)
throws java.io.IOException
- Throws:
java.io.IOException
cleanup
public void cleanup()
throws java.io.IOException
- Throws:
java.io.IOException
cleanup
public void cleanup(int versionsToKeep)
throws java.io.IOException
- Throws:
java.io.IOException
getAllVersions
public java.util.List<java.lang.Long> getAllVersions()
throws java.io.IOException
- Sorted from most recent to oldest
- Throws:
java.io.IOException