voldemort.store.readonly.swapper
Class AdminStoreSwapper
java.lang.Object
voldemort.store.readonly.swapper.StoreSwapper
voldemort.store.readonly.swapper.AdminStoreSwapper
public class AdminStoreSwapper
- extends StoreSwapper
Method Summary |
java.util.List<java.lang.String> |
invokeFetch(java.lang.String storeName,
java.lang.String basePath,
long pushVersion)
|
void |
invokeRollback(java.lang.String storeName,
long pushVersion)
|
void |
invokeSwap(java.lang.String storeName,
java.util.List<java.lang.String> fetchFiles)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AdminStoreSwapper
public AdminStoreSwapper(Cluster cluster,
java.util.concurrent.ExecutorService executor,
AdminClient adminClient,
long timeoutMs,
boolean deleteFailedFetch,
boolean rollbackFailedSwap)
- Parameters:
cluster
- The cluster metadataexecutor
- Executor to use for running parallel fetch / swapsadminClient
- The admin client to use for queryingtimeoutMs
- Time out in msdeleteFailedFetch
- Boolean to indicate we want to delete data on
successful nodes after a fetch fails somewhererollbackFailedSwap
- Boolean to indicate we want to rollback the
data on successful nodes after a swap fails somewhere
AdminStoreSwapper
public AdminStoreSwapper(Cluster cluster,
java.util.concurrent.ExecutorService executor,
AdminClient adminClient,
long timeoutMs)
- Parameters:
cluster
- The cluster metadataexecutor
- Executor to use for running parallel fetch / swapsadminClient
- The admin client to use for queryingtimeoutMs
- Time out in ms
invokeRollback
public void invokeRollback(java.lang.String storeName,
long pushVersion)
- Specified by:
invokeRollback
in class StoreSwapper
invokeFetch
public java.util.List<java.lang.String> invokeFetch(java.lang.String storeName,
java.lang.String basePath,
long pushVersion)
- Specified by:
invokeFetch
in class StoreSwapper
invokeSwap
public void invokeSwap(java.lang.String storeName,
java.util.List<java.lang.String> fetchFiles)
- Specified by:
invokeSwap
in class StoreSwapper
Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu