voldemort.store.readonly.swapper
Class StoreSwapper
java.lang.Object
voldemort.store.readonly.swapper.StoreSwapper
- Direct Known Subclasses:
- AdminStoreSwapper, HttpStoreSwapper
public abstract class StoreSwapper
- extends java.lang.Object
A helper class to invoke the FETCH and SWAP operations on a remote store via
HTTP.
Constructor Summary |
StoreSwapper(Cluster cluster,
java.util.concurrent.ExecutorService executor)
|
Method Summary |
abstract java.util.List<java.lang.String> |
invokeFetch(java.lang.String storeName,
java.lang.String basePath,
long pushVersion)
|
abstract void |
invokeRollback(java.lang.String storeName,
long pushVersion)
|
abstract void |
invokeSwap(java.lang.String storeName,
java.util.List<java.lang.String> fetchFiles)
|
static void |
main(java.lang.String[] args)
|
void |
swapStoreData(java.lang.String storeName,
java.lang.String basePath,
long pushVersion)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
cluster
protected final Cluster cluster
executor
protected final java.util.concurrent.ExecutorService executor
StoreSwapper
public StoreSwapper(Cluster cluster,
java.util.concurrent.ExecutorService executor)
swapStoreData
public void swapStoreData(java.lang.String storeName,
java.lang.String basePath,
long pushVersion)
invokeFetch
public abstract java.util.List<java.lang.String> invokeFetch(java.lang.String storeName,
java.lang.String basePath,
long pushVersion)
invokeSwap
public abstract void invokeSwap(java.lang.String storeName,
java.util.List<java.lang.String> fetchFiles)
invokeRollback
public abstract void invokeRollback(java.lang.String storeName,
long pushVersion)
main
public static void main(java.lang.String[] args)
throws java.lang.Exception
- Throws:
java.lang.Exception
Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu