Package voldemort.xml

Examples of voldemort.xml.StoreDefinitionsMapper

18
19
20
21
22
23
24
25
        this.clusterXmlStr = null;
        this.storeDefList = null;
    }

    public CoordinatorMetadata(String clusterXml, String storesXml) {
        storeMapper = new StoreDefinitionsMapper();
        this.setMetadata(clusterXml, storesXml);
    }
View Full Code Here
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
             */
            if(clusterKey.equals(CLUSTER_VERSION_KEY)) {
                metadataMgmtOps.updateMetadataversion(clusterKey);
            }
            if(storesKey.equals(STORES_VERSION_KEY)) {
                StoreDefinitionsMapper storeDefsMapper = new StoreDefinitionsMapper();
                List<StoreDefinition> storeDefs = storeDefsMapper.readStoreList(new StringReader(storesValue.getValue()));
                if(storeDefs != null) {
                    try {
                        for(StoreDefinition storeDef: storeDefs) {
                            logger.info("Updating metadata version for stores: "
                                        + storeDef.getName());
View Full Code Here
55
56
57
58
59
60
61
62
63
64
    @Before
    public void setup() throws Exception {
        cluster = VoldemortTestConstants.getNineNodeCluster();
        StringReader reader = new StringReader(VoldemortTestConstants.getSingleStore322Xml());
        storeDef = new StoreDefinitionsMapper().readStoreList(reader).get(0);
        routingPlan = new StoreRoutingPlan(cluster, storeDef);
        key = "key1".getBytes();
        keyReplicas = Lists.newArrayList(0, 2, 1);
    }
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
                                                                .setPreferredWrites(1)
                                                                .setRequiredWrites(1)
                                                                .build();
            File file = File.createTempFile("ro-stores-", ".xml");
            FileUtils.writeStringToFile(file,
                                        new StoreDefinitionsMapper().writeStoreList(Lists.newArrayList(store)));
            String storeXmlFile = file.getAbsolutePath();
            Properties props = new Properties();
            props.setProperty("enable.readonly.rest.hdfs", "false");
            props.setProperty("file.fetcher.class", "voldemort.store.readonly.fetcher.HdfsFetcher");
            VoldemortConfig config = ServerTestUtils.createServerConfig(true,
View Full Code Here
211
212
213
214
215
216
217
218
219
220
221
                                                                .setPreferredWrites(1)
                                                                .setRequiredWrites(1)
                                                                .build();
            File file = File.createTempFile("ro-stores-", ".xml");
            FileUtils.writeStringToFile(file,
                                        new StoreDefinitionsMapper().writeStoreList(Lists.newArrayList(store)));
            String storeXmlFile = file.getAbsolutePath();
            Properties props = new Properties();
            props.setProperty("enable.readonly.rest.hdfs", "true");
            props.setProperty("file.fetcher.class",
                              "voldemort.server.protocol.hadoop.RestHadoopFetcher");
View Full Code Here
148
149
150
151
152
153
154
155
156
157
158
                                          "/tmp/vold-build-and-push-" + new Random().nextLong())),
                 new Path(props.getString("output.dir")),
                 new Path(props.getString("input.path")),
                 new ClusterMapper().readCluster(new InputStreamReader(new Path(props.getString("cluster.xml")).getFileSystem(configuration)
                                                                                                               .open(new Path(props.getString("cluster.xml"))))),
                 new StoreDefinitionsMapper().readStoreList(new InputStreamReader(new Path(props.getString("stores.xml")).getFileSystem(configuration)
                                                                                                                         .open(new Path(props.getString("stores.xml"))))),
                 props.getString("store.name"),
                 props.getString("key.selection", null),
                 props.getString("value.selection", null),
                 props.getString("key.transformation.class", null),
View Full Code Here
226
227
228
229
230
231
232
233
234
235
236
                                          "/tmp/vold-build-and-push-" + new Random().nextLong())),
                 new Path(props.getString("output.dir")),
                 new Path(props.getString("input.path")),
                 new ClusterMapper().readCluster(new InputStreamReader(new Path(props.getString("cluster.xml")).getFileSystem(configuration)
                                                                                                               .open(new Path(props.getString("cluster.xml"))))),
                 new StoreDefinitionsMapper().readStoreList(new InputStreamReader(new Path(props.getString("stores.xml")).getFileSystem(configuration)
                                                                                                                         .open(new Path(props.getString("stores.xml"))))),
                 props.getString("store.name"),
                 props.getString("key.selection", null),
                 props.getString("value.selection", null),
                 props.getString("key.transformation.class", null),
View Full Code Here
317
318
319
320
321
322
323
324
325
326
327
                                                                                                key);
                    if(versioned == null || versioned.getValue() == null) {
                        throw new VoldemortException("Value returned from node " + node.getId()
                                                     + " was null");
                    } else if(key.compareTo(MetadataStore.STORES_KEY) == 0) {
                        List<StoreDefinition> storeDefinitions = new StoreDefinitionsMapper().readStoreList(new StringReader(versioned.getValue()));
                        for(StoreDefinition storeDef: storeDefinitions) {
                            String storeName = storeDef.getName();
                            if(storeNodeValueMap.containsKey(storeName) == false) {
                                storeNodeValueMap.put(storeName,
                                                      new HashMap<Object, List<String>>());
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
                                                1,
                                                1,
                                                RoutingStrategyType.CONSISTENT_STRATEGY);
        File tempStoreXml = new File(TestUtils.createTempDir(), "stores.xml");
        FileUtils.writeStringToFile(tempStoreXml,
                                    new StoreDefinitionsMapper().writeStoreList(Lists.newArrayList(storeDef1,
                                                                                                   storeDef2)));

        int numServers = 3;
        servers = new VoldemortServer[numServers];
        int partitionMap[][] = { { 0, 1, 2, 3 }, { 4, 5, 6, 7 }, {} };
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
                                                1,
                                                1,
                                                RoutingStrategyType.CONSISTENT_STRATEGY);
        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
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.