|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| 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" |
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)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||