voldemort.client.rebalance
Class RebalanceClientConfig

java.lang.Object
  extended by voldemort.client.protocol.admin.AdminClientConfig
      extended by voldemort.client.rebalance.RebalanceClientConfig

public class RebalanceClientConfig
extends AdminClientConfig


Field Summary
static java.lang.String EnableDeleteAfterRebalancing
           
static int MAX_PARALLEL_REBALANCING
           
static int MAX_TRIES
           
static java.lang.String MaxParallelRebalancingString
           
static java.lang.String MaxTriesRebalancingString
           
static java.lang.String OutputDirectoryString
           
static int PRIMARY_PARTITION_BATCH_SIZE
           
static java.lang.String PrimaryPartitionBatchSizeString
           
static long REBALANCING_CLIENT_TIMEOUT_SEC
           
static java.lang.String RebalancingClientTimeoutSeconds
           
static boolean STEALER_BASED_REBALANCING
           
static java.lang.String StealerBasedRebalancingString
           
 
Fields inherited from class voldemort.client.protocol.admin.AdminClientConfig
ADMIN_CONNECTION_TIMEOUT_SEC_PROPERTY, ADMIN_SOCKET_BUFFER_SIZE_PROPERTY, ADMIN_SOCKET_KEEPALIVE_PROPERTY, ADMIN_SOCKET_TIMEOUT_SEC_PROPERTY, MAX_BACKOFF_DELAY_MS, MAX_CONNECTIONS_PER_NODE_PROPERTY, MAX_THREADS_PROPERTY, MAX_TOTAL_CONNECTIONS_PROPERTY, RESTORE_DATA_TIMEOUT_SEC, THREAD_IDLE_MS_PROPERTY
 
Constructor Summary
RebalanceClientConfig()
           
RebalanceClientConfig(java.util.Properties properties)
           
 
Method Summary
 int getMaxParallelRebalancing()
           
 int getMaxTriesRebalancing()
           
 java.lang.String getOutputDirectory()
           
 int getPrimaryPartitionBatchSize()
           
 long getRebalancingClientTimeoutSeconds()
           
 boolean hasOutputDirectory()
           
 boolean isDeleteAfterRebalancingEnabled()
           
 boolean isShowPlanEnabled()
           
 boolean isStealerBasedRebalancing()
           
 void setDeleteAfterRebalancingEnabled(boolean deleteAfterRebalancingEnabled)
           
 void setEnableShowPlan(boolean enable)
           
 void setMaxParallelRebalancing(int maxParallelRebalancing)
           
 void setMaxTriesRebalancing(int maxTriesRebalancing)
           
 void setOutputDirectory(java.lang.String outputDirectory)
           
 void setPrimaryPartitionBatchSize(int primaryPartitionBatchSize)
           
 void setRebalancingClientTimeoutSeconds(long rebalancingTimeoutSeconds)
           
 void setStealerBasedRebalancing(boolean stealerBasedRebalancing)
           
 
Methods inherited from class voldemort.client.protocol.admin.AdminClientConfig
getAdminConnectionTimeoutSec, getAdminSocketBufferSize, getAdminSocketKeepAlive, getAdminSocketTimeoutSec, getMaxBackoffDelayMs, getMaxConnectionsPerNode, getMaxThreads, getRestoreDataTimeoutSec, getThreadIdleMs, setAdminConnectionTimeoutSec, setAdminSocketBufferSize, setAdminSocketKeepAlive, setAdminSocketTimeoutSec, setMaxBackoffDelayMs, setMaxConnectionsPerNode, setMaxThreads, setRestoreDataTimeoutSec, setThreadIdleMs
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

MAX_PARALLEL_REBALANCING

public static final int MAX_PARALLEL_REBALANCING
See Also:
Constant Field Values

MAX_TRIES

public static final int MAX_TRIES
See Also:
Constant Field Values

REBALANCING_CLIENT_TIMEOUT_SEC

public static final long REBALANCING_CLIENT_TIMEOUT_SEC
See Also:
Constant Field Values

PRIMARY_PARTITION_BATCH_SIZE

public static final int PRIMARY_PARTITION_BATCH_SIZE
See Also:
Constant Field Values

STEALER_BASED_REBALANCING

public static final boolean STEALER_BASED_REBALANCING
See Also:
Constant Field Values

MaxParallelRebalancingString

public static final java.lang.String MaxParallelRebalancingString
See Also:
Constant Field Values

RebalancingClientTimeoutSeconds

public static final java.lang.String RebalancingClientTimeoutSeconds
See Also:
Constant Field Values

EnableDeleteAfterRebalancing

public static final java.lang.String EnableDeleteAfterRebalancing
See Also:
Constant Field Values

MaxTriesRebalancingString

public static final java.lang.String MaxTriesRebalancingString
See Also:
Constant Field Values

OutputDirectoryString

public static final java.lang.String OutputDirectoryString
See Also:
Constant Field Values

PrimaryPartitionBatchSizeString

public static final java.lang.String PrimaryPartitionBatchSizeString
See Also:
Constant Field Values

StealerBasedRebalancingString

public static final java.lang.String StealerBasedRebalancingString
See Also:
Constant Field Values
Constructor Detail

RebalanceClientConfig

public RebalanceClientConfig(java.util.Properties properties)

RebalanceClientConfig

public RebalanceClientConfig()
Method Detail

setOutputDirectory

public void setOutputDirectory(java.lang.String outputDirectory)

getOutputDirectory

public java.lang.String getOutputDirectory()

hasOutputDirectory

public boolean hasOutputDirectory()

setStealerBasedRebalancing

public void setStealerBasedRebalancing(boolean stealerBasedRebalancing)

isStealerBasedRebalancing

public boolean isStealerBasedRebalancing()

setPrimaryPartitionBatchSize

public void setPrimaryPartitionBatchSize(int primaryPartitionBatchSize)

getPrimaryPartitionBatchSize

public int getPrimaryPartitionBatchSize()

setMaxParallelRebalancing

public void setMaxParallelRebalancing(int maxParallelRebalancing)

getMaxParallelRebalancing

public int getMaxParallelRebalancing()

setMaxTriesRebalancing

public void setMaxTriesRebalancing(int maxTriesRebalancing)

getMaxTriesRebalancing

public int getMaxTriesRebalancing()

setRebalancingClientTimeoutSeconds

public void setRebalancingClientTimeoutSeconds(long rebalancingTimeoutSeconds)

getRebalancingClientTimeoutSeconds

public long getRebalancingClientTimeoutSeconds()

isDeleteAfterRebalancingEnabled

public boolean isDeleteAfterRebalancingEnabled()

setDeleteAfterRebalancingEnabled

public void setDeleteAfterRebalancingEnabled(boolean deleteAfterRebalancingEnabled)

setEnableShowPlan

public void setEnableShowPlan(boolean enable)

isShowPlanEnabled

public boolean isShowPlanEnabled()


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu