Package voldemort.xml

Examples of voldemort.xml.StoreDefinitionsMapper

228
229
230
231
232
233
234
235
236
237
238
                                                .setPreferredWrites(1)
                                                .setRequiredWrites(1)
                                                .build();
        File tempStoreXml = new File(TestUtils.createTempDir(), "stores.xml");
        FileUtils.writeStringToFile(tempStoreXml,
                                    new StoreDefinitionsMapper().writeStoreList(Lists.newArrayList(storeDef1,
                                                                                                   storeDef2)));

        int numServers = 4;
        servers = new VoldemortServer[numServers];
        int partitionMap[][] = { { 0, 1, 2, 3 }, { 4, 5, 6, 7 }, { 8, 9, 10, 11 }, {} };
View Full Code Here
294
295
296
297
298
299
300
301
302
303
304
                                                1,
                                                RoutingStrategyType.CONSISTENT_STRATEGY);

        File tempStoreXml = new File(TestUtils.createTempDir(), "stores.xml");
        FileUtils.writeStringToFile(tempStoreXml,
                                    new StoreDefinitionsMapper().writeStoreList(Lists.newArrayList(storeDef1,
                                                                                                   storeDef2,
                                                                                                   storeDef3,
                                                                                                   storeDef4)));

        int numServers = 4;
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
        sourceStoreDefs = ClusterTestUtils.getZZZStoreDefsBDB();
        targetStoreDefs = RebalanceUtils.dropZone(sourceStoreDefs, DROP_ZONE_ID);

        File sourceStoreDefsXml = File.createTempFile("zzz-stores-", ".xml");
        FileUtils.writeStringToFile(sourceStoreDefsXml,
                                    new StoreDefinitionsMapper().writeStoreList(sourceStoreDefs));
        servers = new VoldemortServer[sourceCluster.getNumberOfNodes()];

        ServerTestUtils.startVoldemortCluster(servers,
                                              null,
                                              null,
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
            }
        }

        // shrink the cluster, by dropping zone 0
        String clusterXmlString = new ClusterMapper().writeCluster(targetCluster);
        String storesXmlString = new StoreDefinitionsMapper().writeStoreList(targetStoreDefs);
        int[] remoteNodeList = new int[sourceCluster.getNumberOfNodes()];
        int ni = 0;
        for(Integer nodeId: sourceCluster.getNodeIds()) {
            remoteNodeList[ni++] = nodeId;
        }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
        VoldemortConfig config = new VoldemortConfig(0, temp.getAbsolutePath());
        new File(config.getMetadataDirectory()).mkdir();
        this.serverMap = new HashMap<Integer, VoldemortServer>();
        this.scheduler = new SchedulerService(1, new MockTime());
        this.cluster = VoldemortTestConstants.getNineNodeCluster();
        StoreDefinitionsMapper mapper = new StoreDefinitionsMapper();
        this.storeDefs = mapper.readStoreList(new StringReader((VoldemortTestConstants.getSingleStore322Xml())));
        this.storeRepository = new StoreRepository();
        this.metadataStore = ServerTestUtils.createMetadataStore(cluster, storeDefs);
        storage = new StorageService(storeRepository, metadataStore, scheduler, config);
        // Start the storage service
        storage.start();
        this.socketStoreFactory = new ClientRequestExecutorPool(2, 10000, 100000, 32 * 1024);
        String storeDefsString = mapper.writeStoreList(storeDefs);
        File file = null;
        try {
            file = File.createTempFile("single-store-", ".xml");
            FileUtils.writeStringToFile(file, storeDefsString);
            String storeDefFile = file.getAbsolutePath();
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
140
    }

    private HashMap<String, String> generateKeysForMasterNode(int numKeys) throws IOException {
        // Assumes master node is 0 and generates keys that goes to master node
        HashMap<String, String> keyValuePairs = new HashMap<String, String>();
        StoreDefinitionsMapper storedDefMapper = new StoreDefinitionsMapper();
        List<StoreDefinition> storeDefs = storedDefMapper.readStoreList(new File(storesxml));
        StoreDefinition testStoreDef = storeDefs.get(0);
        BaseStoreRoutingPlan baseStoreRoutingPlan = new BaseStoreRoutingPlan(cluster, testStoreDef);

        /*
         * Generating simple key values pairs of the form 3:3 where key and
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
                                                        true,
                                                        null,
                                                        "test/common/voldemort/config/single-store-322.xml",
                                                        new Properties());
        StringReader reader = new StringReader(VoldemortTestConstants.getSingleStore322Xml());
        StoreDefinition storeDef = new StoreDefinitionsMapper().readStoreList(reader).get(0);

        currentRoutingPlan = new BaseStoreRoutingPlan(cluster, storeDef);

        String bootStrapUrl = "";
        for(VoldemortServer server: servers) {
View Full Code Here
363
364
365
366
367
368
369
370
371
372
373
                    rebalanceTaskInfo.add(ProtoUtils.decodeRebalanceTaskInfoMap(map));
                }

                Cluster cluster = new ClusterMapper().readCluster(new StringReader(request.getClusterString()));

                List<StoreDefinition> storeDefs = new StoreDefinitionsMapper().readStoreList(new StringReader(request.getStoresString()));
                boolean swapRO = request.getSwapRo();
                boolean changeClusterMetadata = request.getChangeClusterMetadata();
                boolean changeRebalanceState = request.getChangeRebalanceState();
                boolean rollback = request.getRollback();
View Full Code Here
1474
1475
1476
1477
1478
1479
1480
1481
1482
1483
1484
1485
            return response.build();
        }

        try {
            // adding a store requires decoding the passed in store string
            StoreDefinitionsMapper mapper = new StoreDefinitionsMapper();
            StoreDefinition def = mapper.readStore(new StringReader(request.getStoreDefinition()));

            synchronized(lock) {
                // only allow a single store to be created at a time. We'll see
                // concurrent errors when writing the
                // stores.xml file out otherwise. (see
View Full Code Here
420
421
422
423
424
425
426
427
428
429
430
    public static StoreDefinition readStoreDef(String storeFile,
                                               String storeName,
                                               Configuration conf) throws IOException {

        List<StoreDefinition> stores = new StoreDefinitionsMapper().readStoreList(new StringReader(readAsString(new Path(storeFile))));
        for(StoreDefinition def: stores) {
            if(def.getName().equals(storeName))
                return def;
        }
        throw new RuntimeException("Can't find store definition for store '" + storeName + "'.");
View Full Code Here
TOP

Related Classes of voldemort.xml.StoreDefinitionsMapper

  • org.jdom.Document
  • org.jdom.Element
  • org.jdom.input.SAXBuilder
  • org.jdom.output.XMLOutputter
  • org.jdom.transform.JDOMSource
  • voldemort.client.AdminFetchTest
  • voldemort.client.AdminServiceBasicTest
  • voldemort.client.AdminServiceFilterTest
  • voldemort.client.AdminServiceMultiJVMTest
  • voldemort.client.AtomicSetMetadataPairTest
    • 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.