Package com.splout.db.common

Examples of com.splout.db.common.ReplicationEntry

206
207
208
209
210
211
212
213
214
215
216
    handler.init(SploutConfiguration.getTestConfig());

    SploutConfiguration config = SploutConfiguration.getTestConfig();
    DNode dnode = TestUtils.getTestDNode(config, dHandler, "dnode-" + this.getClass().getName() + "-2");
    try {
      ReplicationEntry repEntry = new ReplicationEntry(0, dnode.getAddress());
      Tablespace tablespace1 = new Tablespace(PartitionMap.oneShardOpenedMap(), new ReplicationMap(
          Arrays.asList(repEntry)), 0l, 0l);
      handler.getContext().getTablespaceVersionsMap()
          .put(new TablespaceVersion("tablespace1", 0l), tablespace1);
      handler.getContext().getCurrentVersionsMap().put("tablespace1", 0l);
View Full Code Here
233
234
235
236
237
238
239
240
241
242
243
    handler.init(SploutConfiguration.getTestConfig());

    SploutConfiguration config = SploutConfiguration.getTestConfig();
    DNode dnode = TestUtils.getTestDNode(config, dHandler, "dnode-" + this.getClass().getName() + "-6");
    try {
      ReplicationEntry repEntry = new ReplicationEntry(0, dnode.getAddress());
      Tablespace tablespace1 = new Tablespace(PartitionMap.oneShardOpenedMap(), new ReplicationMap(
          Arrays.asList(repEntry)), 0l, 0l);
      handler.getContext().getTablespaceVersionsMap()
          .put(new TablespaceVersion("tablespace1", 0l), tablespace1);
      handler.getContext().getCurrentVersionsMap().put("tablespace1", 0l);
View Full Code Here
388
389
390
391
392
393
394
395
396
397
398
399
    }, "dnode-" + this.getClass().getName() + "-4");

    QNodeHandler handler = new QNodeHandler();
    try {
      handler.init(config1);
      ReplicationEntry repEntry1 = new ReplicationEntry(0, dnode1.getAddress(), dnode2.getAddress());
      ReplicationEntry repEntry2 = new ReplicationEntry(0, dnode1.getAddress());

      DeployRequest deployRequest1 = new DeployRequest();
      deployRequest1.setTablespace("partition1");
      deployRequest1.setPartitionMap(PartitionMap.oneShardOpenedMap().getPartitionEntries());
      deployRequest1.setReplicationMap(Arrays.asList(repEntry1));
View Full Code Here
483
484
485
486
487
488
489
490
491
492
493
    }, "dnode-" + this.getClass().getName() + "-5");

    try {
      handler.init(config);

      ReplicationEntry repEntry = new ReplicationEntry(0, dnode.getAddress());

      DeployRequest deployRequest = new DeployRequest();
      deployRequest.setTablespace("partition1");
      deployRequest.setPartitionMap(PartitionMap.oneShardOpenedMap().getPartitionEntries());
      deployRequest.setReplicationMap(Arrays.asList(repEntry));
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
      partitionEntry.setMin((i * 10) + "");
      partitionEntry.setMax((i * 10 + 10) + "");
      partitionEntry.setShard(i);
      partitions.add(partitionEntry);
      // And the replication
      ReplicationEntry repEntry = new ReplicationEntry();
      repEntry.setShard(i);
      int j = i + 1;
      if(j == nDnodes) {
        j = 0;
      }
      repEntry.setNodes(Arrays.asList(new String[] { dNodes.get(i).getAddress(), dNodes.get(j).getAddress() }));
      replicationEntries.add(repEntry);
    }
    // A valid partition map is complete: first min is null and last max is null.
    partitions.get(0).setMin(null);
    partitions.get(partitions.size() - 1).setMax(null);
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
105
    uniqueShards.addAll(Arrays.asList(shards));
    assertEquals(uniqueShards.size(), tablespace.getPartitionMap().getPartitionEntries().size());
    assertEquals(uniqueShards.size(), tablespace.getReplicationMap().getReplicationEntries().size());
    int k = 0;
    for(int i = 0; i < uniqueShards.size(); i++) {
      ReplicationEntry entry = tablespace.getReplicationMap().getReplicationEntries().get(i);
      for(int j = 0; j < entry.getNodes().size(); j++, k++) {
        assertEquals(dnodes[k], entry.getNodes().get(j));
        assertEquals(shards[k], entry.getShard());
      }
    }
  }
View Full Code Here
TOP

Related Classes of com.splout.db.common.ReplicationEntry

  • com.splout.db.integration.BaseIntegrationTest
  • com.splout.db.qnode.Deployer
  • com.splout.db.qnode.QNodeHandlerContext
  • com.splout.db.qnode.TestDeployAbort
  • com.splout.db.qnode.TestDeployFailover
  • com.splout.db.qnode.TestFailOver
  • com.splout.db.qnode.TestMultiQuery
  • com.splout.db.qnode.TestQNodeHandler
  • com.splout.db.qnode.TestQNodeHandlerContext
  • com.splout.db.qnode.TestQuerier
    • 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.