Package voldemort.client.rebalance

Examples of voldemort.client.rebalance.RebalanceBatchPlan$RebalanceTaskInfoBuilder


     * @return list of tasks for this batch plan
     */
    public static List<RebalanceTaskInfo> getBatchPlan(Cluster currentCluster,
                                                       Cluster finalCluster,
                                                       List<StoreDefinition> storeDef) {
        RebalanceBatchPlan rebalancePlan = new RebalanceBatchPlan(currentCluster,
                                                                  finalCluster,
                                                                  storeDef);
        return rebalancePlan.getBatchPlan();
    }
View Full Code Here


     */
    public static List<RebalanceTaskInfo> getBatchPlan(Cluster currentCluster,
                                                       List<StoreDefinition> currentStoreDefs,
                                                       Cluster finalCluster,
                                                       List<StoreDefinition> finalStoreDefs) {
        RebalanceBatchPlan rebalancePlan = new RebalanceBatchPlan(currentCluster,
                                                                  currentStoreDefs,
                                                                  finalCluster,
                                                                  finalStoreDefs);
        return rebalancePlan.getBatchPlan();
    }
View Full Code Here

        for(ByteArray key: this.proxyPutTestSecondaryEntries.keySet()) {
            this.secondaryEntriesMoved.remove(key);
        }
        assertTrue("Not enough secondary entries", primaryEntriesMoved.size() > 1);

        RebalanceBatchPlan RebalanceBatchPlan = new
                RebalanceBatchPlan(currentCluster,
                                   targetCluster,
                                   Lists.newArrayList(storeDef));
        List<RebalanceTaskInfo> plans =
                Lists.newArrayList(RebalanceBatchPlan.getBatchPlan());

        // Set into rebalancing state
        for(RebalanceTaskInfo partitionPlan: plans) {
            servers[partitionPlan.getStealerId()].getMetadataStore()
                                                 .put(MetadataStore.SERVER_STATE_KEY,
View Full Code Here

TOP

Related Classes of voldemort.client.rebalance.RebalanceBatchPlan$RebalanceTaskInfoBuilder

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.