Uses of Class
voldemort.cluster.Cluster

Packages that use Cluster
voldemort.client The user facing interface to Voldemort. 
voldemort.client.protocol.admin Classes that abstract admin based Voldemort requests. 
voldemort.client.rebalance All classes associated with the rebalance controller tool. 
voldemort.cluster.failuredetector Classes associated with client side failure detectors. 
voldemort.routing Routing strategies for mapping requests into the Voldemort cluster. 
voldemort.server The Voldemort server. 
voldemort.server.jmx Service which deals with the JMX registration 
voldemort.server.protocol.admin Server side implementation of admin based requests 
voldemort.server.rebalance Classes dealing with rebalancing on the server side. 
voldemort.server.storage The storage service which handles instantiating all the stores and their corresponding engines. 
voldemort.store.metadata Our in-memory metadata store on the server which is backed by the configuration files. 
voldemort.store.readonly A storage engine that provides very efficient read-only access to large sorted files of data. 
voldemort.store.readonly.swapper Classes used for fetching and swapping read-only stores. 
voldemort.store.routed A store implmentation that handles routing to nodes, and repairing obsolete values detected on those nodes. 
voldemort.store.slop A store implementation that falls back on storing values in additional nodes not in the preference list when nodes are unavailable. 
voldemort.store.slop.strategy Bunch of different ways in which we would store failed requests for the Hinted handoff feature. 
voldemort.store.stats Store wrappers which deal with statistics 
voldemort.utils Basic helper functions. 
voldemort.xml Classes related to parsing our metadata ( cluster + store definition ) 
 

Uses of Cluster in voldemort.client
 

Methods in voldemort.client with parameters of type Cluster
protected  FailureDetector SocketStoreClientFactory.initFailureDetector(ClientConfig config, Cluster cluster)
           
protected  FailureDetector HttpStoreClientFactory.initFailureDetector(ClientConfig config, Cluster cluster)
           
protected abstract  FailureDetector AbstractStoreClientFactory.initFailureDetector(ClientConfig config, Cluster cluster)
           
 

Uses of Cluster in voldemort.client.protocol.admin
 

Methods in voldemort.client.protocol.admin that return Cluster
 Cluster AdminClient.getAdminClientCluster()
          Get the cluster info AdminClient is using.
 

Methods in voldemort.client.protocol.admin that return types with arguments of type Cluster
 Versioned<Cluster> AdminClient.MetadataManagementOperations.getRemoteCluster(int nodeId)
          Get the cluster information from a remote node.
 

Methods in voldemort.client.protocol.admin with parameters of type Cluster
 long AdminClient.StoreMaintenanceOperations.deletePartitions(int nodeId, java.lang.String storeName, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList, Cluster initialCluster, VoldemortFilter filter)
          Delete all entries belonging to all the partitions passed as a map of replica_type to partition list.
 java.util.Iterator<Pair<ByteArray,Versioned<byte[]>>> AdminClient.BulkStreamingFetchOperations.fetchEntries(int nodeId, java.lang.String storeName, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList, VoldemortFilter filter, boolean fetchMasterEntries, Cluster initialCluster, long skipRecords)
          Fetch key/value tuples belonging to this map of replica type to partition list
 java.util.Iterator<ByteArray> AdminClient.BulkStreamingFetchOperations.fetchKeys(int nodeId, java.lang.String storeName, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList, VoldemortFilter filter, boolean fetchMasterEntries, Cluster initialCluster, long skipRecords)
          Fetch all keys belonging to the map of replica type to partition list.
 java.util.Map<java.lang.Integer,java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>> AdminClient.HelperOperations.getReplicationMapping(int restoringNode, Cluster cluster, StoreDefinition storeDef)
          For a particular node, finds out all the [replica, partition] tuples it needs to steal in order to be brought back to normal state
 java.util.Map<java.lang.Integer,java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>> AdminClient.HelperOperations.getReplicationMapping(int restoringNode, Cluster cluster, StoreDefinition storeDef, int zoneId)
          For a particular node, finds out all the [replica, partition] tuples it needs to steal in order to be brought back to normal state
 int AdminClient.StoreMaintenanceOperations.migratePartitions(int donorNodeId, int stealerNodeId, java.lang.String storeName, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList, VoldemortFilter filter, Cluster initialCluster, boolean optimize)
          Migrate keys/values belonging to a map of replica type to partition list from donor node to stealer node.
 void AdminClient.RebalancingOperations.rebalanceStateChange(Cluster existingCluster, Cluster transitionCluster, java.util.List<RebalancePartitionsInfo> rebalancePartitionPlanList, boolean swapRO, boolean changeClusterMetadata, boolean changeRebalanceState, boolean rollback, boolean failEarly)
          Used in rebalancing to indicate change in states.
 void AdminClient.setAdminClientCluster(Cluster cluster)
          Set cluster info for AdminClient to use.
 void AdminClient.MetadataManagementOperations.updateRemoteCluster(int nodeId, Cluster cluster, Version clock)
          Update the cluster information MetadataStore.CLUSTER_KEY on a remote node.
 

Constructors in voldemort.client.protocol.admin with parameters of type Cluster
AdminClient(Cluster cluster, AdminClientConfig adminClientConfig)
          Create an instance of AdminClient given a Cluster object.
 

Uses of Cluster in voldemort.client.rebalance
 

Methods in voldemort.client.rebalance that return Cluster
 Cluster OrderedClusterTransition.getCurrentCluster()
           
 Cluster RebalancePartitionsInfo.getInitialCluster()
           
 Cluster OrderedClusterTransition.getTargetCluster()
           
 

Methods in voldemort.client.rebalance with parameters of type Cluster
 void RebalanceController.rebalance(Cluster targetCluster)
          Grabs the latest cluster definition RebalanceController.rebalance(voldemort.cluster.Cluster, voldemort.cluster.Cluster)
 void RebalanceController.rebalance(Cluster currentCluster, Cluster targetCluster)
          Grabs the store definition and calls RebalanceController.rebalance(voldemort.cluster.Cluster, voldemort.cluster.Cluster, java.util.List)
 void RebalanceController.rebalance(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs)
          Does basic verification of the metadata + server state.
 

Constructors in voldemort.client.rebalance with parameters of type Cluster
OrderedClusterTransition(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs, RebalanceClusterPlan rebalanceClusterPlan)
           
RebalanceClusterPlan(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs, boolean enabledDeletePartition)
          Compares the currentCluster configuration with the desired targetConfiguration and builds a map of Target node-id to map of source node-ids and partitions desired to be stolen/fetched.
RebalanceClusterPlan(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs, boolean enabledDeletePartition, boolean isStealerBased)
          Compares the currentCluster configuration with the desired targetConfiguration and builds a map of Target node-id to map of source node-ids and partitions desired to be stolen/fetched.
RebalanceController(Cluster cluster, RebalanceClientConfig config)
           
RebalancePartitionsInfo(int stealerNodeId, int donorId, java.util.HashMap<java.lang.String,java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>> storeToReplicaToAddPartitionList, java.util.HashMap<java.lang.String,java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>> storeToReplicaToDeletePartitionList, Cluster initialCluster, int attempt)
          Rebalance Partitions info maintains all information needed for rebalancing for a stealer-donor node tuple
 

Uses of Cluster in voldemort.cluster.failuredetector
 

Methods in voldemort.cluster.failuredetector that return Cluster
 Cluster FailureDetectorConfig.getCluster()
          Returns a reference to the cluster object
 

Methods in voldemort.cluster.failuredetector with parameters of type Cluster
 FailureDetectorConfig FailureDetectorConfig.setCluster(Cluster cluster)
          Assigns a cluster which determines the source of truth for the topology
 

Uses of Cluster in voldemort.routing
 

Methods in voldemort.routing with parameters of type Cluster
 RoutingStrategy RoutingStrategyFactory.updateRoutingStrategy(StoreDefinition storeDef, Cluster cluster)
           
 

Uses of Cluster in voldemort.server
 

Constructors in voldemort.server with parameters of type Cluster
VoldemortServer(VoldemortConfig config, Cluster cluster)
           
 

Uses of Cluster in voldemort.server.jmx
 

Constructors in voldemort.server.jmx with parameters of type Cluster
JmxService(VoldemortServer server, Cluster cluster, StoreRepository storeRepository, java.util.Collection<VoldemortService> services)
           
 

Uses of Cluster in voldemort.server.protocol.admin
 

Fields in voldemort.server.protocol.admin declared as Cluster
protected  Cluster FetchStreamRequestHandler.initialCluster
           
 

Uses of Cluster in voldemort.server.rebalance
 

Methods in voldemort.server.rebalance with parameters of type Cluster
 void Rebalancer.rebalanceStateChange(Cluster cluster, java.util.List<RebalancePartitionsInfo> rebalancePartitionsInfo, boolean swapRO, boolean changeClusterMetadata, boolean changeRebalanceState, boolean rollback)
          Support four different stages
For normal operation:
 

Uses of Cluster in voldemort.server.storage
 

Methods in voldemort.server.storage with parameters of type Cluster
 void StorageService.registerNodeStores(StoreDefinition def, Cluster cluster, int localNode)
          For server side routing create NodeStore (socketstore) and pass it on to a RebootstrappingStore.
 

Uses of Cluster in voldemort.store.metadata
 

Methods in voldemort.store.metadata that return Cluster
 Cluster MetadataStore.getCluster()
           
 

Uses of Cluster in voldemort.store.readonly
 

Constructors in voldemort.store.readonly with parameters of type Cluster
JsonStoreBuilder(JsonReader reader, Cluster cluster, StoreDefinition storeDefinition, RoutingStrategy routingStrategy, java.io.File outputDir, java.io.File tempDir, int internalSortSize, int numThreads, int numChunks, int ioBufferSize, boolean gzipIntermediate)
           
 

Uses of Cluster in voldemort.store.readonly.swapper
 

Fields in voldemort.store.readonly.swapper declared as Cluster
protected  Cluster StoreSwapper.cluster
           
 

Constructors in voldemort.store.readonly.swapper with parameters of type Cluster
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)
           
HttpStoreSwapper(Cluster cluster, java.util.concurrent.ExecutorService executor, org.apache.http.client.HttpClient httpClient, java.lang.String readOnlyMgmtPath)
           
HttpStoreSwapper(Cluster cluster, java.util.concurrent.ExecutorService executor, org.apache.http.client.HttpClient httpClient, java.lang.String readOnlyMgmtPath, boolean deleteFailedFetch, boolean rollbackFailedSwap)
           
StoreSwapper(Cluster cluster, java.util.concurrent.ExecutorService executor)
           
 

Uses of Cluster in voldemort.store.routed
 

Methods in voldemort.store.routed with parameters of type Cluster
 RoutedStore RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, boolean repairReads, FailureDetector failureDetector)
           
 RoutedStore RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, boolean repairReads, int clientZoneId, FailureDetector failureDetector)
           
 RoutedStore RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, boolean repairReads, int clientZoneId, FailureDetector failureDetector, boolean jmxEnabled, int jmxId)
           
 

Constructors in voldemort.store.routed with parameters of type Cluster
PipelineRoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, Cluster cluster, StoreDefinition storeDef, boolean repairReads, int clientZoneId, TimeoutConfig timeoutConfig, FailureDetector failureDetector, boolean jmxEnabled, int jmxId)
          Create a PipelineRoutedStore
RoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, Cluster cluster, StoreDefinition storeDef, boolean repairReads, TimeoutConfig timeoutConfig, FailureDetector failureDetector, Time time)
           
ThreadPoolRoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, Cluster cluster, StoreDefinition storeDef, boolean repairReads, java.util.concurrent.ExecutorService threadPool, TimeoutConfig timeoutConfig, FailureDetector failureDetector, Time time)
          Create a RoutedStoreClient
ThreadPoolRoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, Cluster cluster, StoreDefinition storeDef, int numberOfThreads, boolean repairReads, TimeoutConfig timeoutConfig, FailureDetector failureDetector)
          Create a RoutedStoreClient
 

Uses of Cluster in voldemort.store.slop
 

Constructors in voldemort.store.slop with parameters of type Cluster
SlopStorageEngine(StorageEngine<ByteArray,byte[],byte[]> slopEngine, Cluster cluster)
           
 

Uses of Cluster in voldemort.store.slop.strategy
 

Methods in voldemort.store.slop.strategy with parameters of type Cluster
 HintedHandoffStrategy HintedHandoffStrategyFactory.updateHintedHandoffStrategy(StoreDefinition storeDef, Cluster cluster)
           
 

Constructors in voldemort.store.slop.strategy with parameters of type Cluster
ConsistentHandoffStrategy(Cluster cluster, int prefListSize, boolean enableZoneRouting, int clientZoneId)
          Creates a consistent handoff strategy instance
HandoffToAnyStrategy(Cluster cluster, boolean enableZoneRouting, int clientZoneId)
          Creates a to-any handoff strategy instance
ProximityHandoffStrategy(Cluster cluster, int clientZoneId)
          Constructor which makes zone based mapping
 

Uses of Cluster in voldemort.store.stats
 

Constructors in voldemort.store.stats with parameters of type Cluster
ClusterWideCounter(Cluster cluster)
           
SlopStats(Cluster cluster)
           
 

Uses of Cluster in voldemort.utils
 

Methods in voldemort.utils that return Cluster
static Cluster RebalanceUtils.createUpdatedCluster(Cluster currentCluster, int stealerNodeId, java.util.List<java.lang.Integer> donatedPartitions)
          Updates the existing cluster such that we remove partitions mentioned from the stealer node and add them to the donor node
static Cluster RebalanceUtils.getClusterWithNewNodes(Cluster currentCluster, Cluster targetCluster)
          Given the current cluster and a target cluster, generates a cluster with new nodes ( which in turn contain empty partition lists )
static Cluster RebalanceUtils.updateCluster(Cluster currentCluster, java.util.List<Node> updatedNodeList)
          Concatenates the list of current nodes in the given cluster with the new nodes provided and returns an updated cluster metadata.
 

Methods in voldemort.utils that return types with arguments of type Cluster
static Pair<Cluster,java.lang.Integer> RebalanceUtils.generateMinCluster(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs)
          Takes the current cluster metadata and target cluster metadata ( which contains all the nodes of current cluster + new nodes with empty partitions ), and generates a new cluster with some partitions moved to the new node
static Versioned<Cluster> RebalanceUtils.getLatestCluster(java.util.List<java.lang.Integer> requiredNodes, AdminClient adminClient)
          Get the latest cluster from all available nodes in the cluster
Throws exception if:
A) Any node in the required nodes list fails to respond.
B) Cluster is in inconsistent state with concurrent versions for cluster metadata on any two nodes.
 

Methods in voldemort.utils with parameters of type Cluster
static boolean RebalanceUtils.checkKeyBelongsToNode(byte[] key, int nodeId, Cluster cluster, StoreDefinition storeDef)
           
static java.util.List<java.lang.Integer> RebalanceUtils.checkKeyBelongsToPartition(byte[] key, java.util.Set<Pair<java.lang.Integer,java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>>> stealerNodeToMappingTuples, Cluster cluster, StoreDefinition storeDef)
          Given a key and a list of steal infos give back a list of stealer node ids which will steal this.
static boolean RebalanceUtils.checkKeyBelongsToPartition(int nodeId, byte[] key, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList, Cluster cluster, StoreDefinition storeDef)
          Check that the key belongs to one of the partitions in the map of replica type to partitions
static boolean RebalanceUtils.checkPartitionBelongsToNode(int partition, int nodeId, Cluster cluster, StoreDefinition storeDef)
          Checks if a given partition is stored in the node.
static boolean RebalanceUtils.checkPartitionBelongsToNode(int partition, int replicaType, int nodeId, Cluster cluster, StoreDefinition storeDef)
           
static boolean RebalanceUtils.containsNode(Cluster cluster, int nodeId)
          Given a cluster and a node id checks if the node exists
static boolean RebalanceUtils.containsPreferenceList(Cluster cluster, java.util.List<java.lang.Integer> preferenceList, int nodeId)
          Given a preference list and a node id, check if any one of the partitions is on the node in picture
static AdminClient RebalanceUtils.createTempAdminClient(VoldemortConfig voldemortConfig, Cluster cluster, int numConnPerNode)
           
static Cluster RebalanceUtils.createUpdatedCluster(Cluster currentCluster, int stealerNodeId, java.util.List<java.lang.Integer> donatedPartitions)
          Updates the existing cluster such that we remove partitions mentioned from the stealer node and add them to the donor node
static void RebalanceUtils.dumpCluster(Cluster initialCluster, Cluster finalCluster, java.io.File outputDir)
          Given the initial and final cluster dumps it into the output directory
static java.util.HashMap<java.lang.Integer,java.lang.Double> KeyDistributionGenerator.generateDistribution(Cluster cluster, StoreDefinition storeDef, java.util.List<ByteArray> keys)
          Generates distribution for a specific store definition
 void Entropy.generateEntropy(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.io.File storeDir, boolean opType)
          Run the actual entropy calculation tool
 void Entropy.generateEntropy(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.io.File storeDir, boolean opType, boolean negativeTest)
          Run the actual entropy calculation tool
static Pair<Cluster,java.lang.Integer> RebalanceUtils.generateMinCluster(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs)
          Takes the current cluster metadata and target cluster metadata ( which contains all the nodes of current cluster + new nodes with empty partitions ), and generates a new cluster with some partitions moved to the new node
static void RebalanceUtils.generateMinCluster(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs, java.lang.String outputDir, int tries)
          Outputs an optimized cluster based on the existing cluster and the new nodes that are being added.
static java.util.HashMap<java.lang.Integer,java.lang.Double> KeyDistributionGenerator.generateOverallDistribution(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.util.List<ByteArray> keys)
           
static java.util.HashMap<java.lang.Integer,java.lang.Double> KeyDistributionGenerator.generateOverallDistributionWithUniqueStores(Cluster cluster, java.util.HashMap<StoreDefinition,java.lang.Integer> uniqueStoreDefsWithCount, java.util.List<ByteArray> keys)
           
static Cluster RebalanceUtils.getClusterWithNewNodes(Cluster currentCluster, Cluster targetCluster)
          Given the current cluster and a target cluster, generates a cluster with new nodes ( which in turn contain empty partition lists )
static int RebalanceUtils.getCrossZoneMoves(Cluster targetCluster, RebalanceClusterPlan plan)
          Return the number of cross zone copying that is going to take place
static java.util.Map<java.lang.Integer,java.lang.Integer> RebalanceUtils.getCurrentPartitionMapping(Cluster currentCluster)
          Given the cluster metadata returns a mapping of partition to node
static Node RebalanceUtils.getNodeByPartitionId(Cluster cluster, int partitionId)
          Returns the Node associated to the provided partition.
static java.util.Map<java.lang.Integer,java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>> RebalanceUtils.getNodeIdToAllPartitions(Cluster cluster, StoreDefinition storeDef, boolean includePrimary)
          For a particular cluster creates a mapping of node id to their corresponding list of [ replicaType, partition ] tuple
static java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> RebalanceUtils.getOptimizedReplicaToPartitionList(int stealerNodeId, Cluster cluster, StoreDefinition storeDef, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> currentReplicaToPartitionList)
          Given the current replica to partition list, try to check if the donor node would already contain that partition and if yes, ignore it
static java.util.Map<java.lang.Integer,java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>> RebalanceUtils.getStolenPartitionTuples(Cluster currentCluster, Cluster targetCluster, StoreDefinition storeDef)
          Find all [replica_type, partition] tuples to be stolen
static java.util.List<java.lang.Integer> RebalanceUtils.getStolenPrimaryPartitions(Cluster currentCluster, Cluster targetCluster, int stealNodeId)
          For a particular stealer node find all the "primary" tuples it will steal.
static java.util.List<StoreDefinition> RebalanceUtils.getStoreDefinition(Cluster cluster, AdminClient adminClient)
          Given the cluster metadata and admin client, retrieves the list of store definitions.
static java.lang.String KeyDistributionGenerator.printOverallDistribution(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.util.List<ByteArray> keys)
          Given the cluster metadata and list of store definitions, presents a string of the distribution
static java.lang.String KeyDistributionGenerator.printStoreWiseDistribution(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.util.List<ByteArray> keys)
          Given the cluster metadata and list of store definitions, presents a string of the store wise distribution
static void RebalanceUtils.propagateCluster(AdminClient adminClient, Cluster cluster)
          Attempt to propagate a cluster definition to all nodes.
static Cluster RebalanceUtils.updateCluster(Cluster currentCluster, java.util.List<Node> updatedNodeList)
          Concatenates the list of current nodes in the given cluster with the new nodes provided and returns an updated cluster metadata.
static void RebalanceUtils.validateClusterState(Cluster cluster, AdminClient adminClient)
          Check the execution state of the server by checking the state of MetadataStore.VoldemortState
This function checks if the nodes are all in normal state ( MetadataStore.VoldemortState.NORMAL_SERVER).
static void RebalanceUtils.validateReadOnlyStores(Cluster cluster, java.util.List<StoreDefinition> storeDefs, AdminClient adminClient)
          Given a list of store definitions, cluster and admin client returns a boolean indicating if all RO stores are in the correct format.
 

Constructors in voldemort.utils with parameters of type Cluster
KeyLocationValidation(Cluster cluster, int nodeId, StoreDefinition storeDef, ByteArray keyList)
           
 

Uses of Cluster in voldemort.xml
 

Methods in voldemort.xml that return Cluster
 Cluster ClusterMapper.readCluster(java.io.File f)
           
 Cluster ClusterMapper.readCluster(java.io.Reader input)
           
 Cluster ClusterMapper.readCluster(java.io.Reader input, boolean verifySchema)
           
 

Methods in voldemort.xml with parameters of type Cluster
 java.lang.String ClusterMapper.writeCluster(Cluster cluster)
           
 



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