voldemort.store.readonly.swapper
Class AdminStoreSwapper

java.lang.Object
  voldemort.store.readonly.swapper.StoreSwapper
      voldemort.store.readonly.swapper.AdminStoreSwapper

public class AdminStoreSwapper
extends StoreSwapper

Field Summary

Fields inherited from class voldemort.store.readonly.swapper.StoreSwapper

cluster, executor

Constructor Summary

AdminStoreSwapper(Cluster cluster, java.util.concurrent.ExecutorService executor, AdminClient adminClient, long timeoutMs)

AdminStoreSwapper(Cluster cluster, java.util.concurrent.ExecutorService executor, AdminClient adminClient, long timeoutMs, boolean deleteFailedFetch, boolean rollbackFailedSwap)

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 voldemort.store.readonly.swapper.StoreSwapper

main, swapStoreData

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AdminStoreSwapper

public AdminStoreSwapper(Cluster cluster,
                         java.util.concurrent.ExecutorService executor,
                         AdminClient adminClient,
                         long timeoutMs,
                         boolean deleteFailedFetch,
                         boolean rollbackFailedSwap)

Parameters:

cluster - The cluster metadata

executor - Executor to use for running parallel fetch / swaps

adminClient - The admin client to use for querying

timeoutMs - Time out in ms

deleteFailedFetch - Boolean to indicate we want to delete data on successful nodes after a fetch fails somewhere

rollbackFailedSwap - 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 metadata

executor - Executor to use for running parallel fetch / swaps

adminClient - The admin client to use for querying

timeoutMs - Time out in ms

Method Detail

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