accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [38/51] [abbrv] git commit: ACCUMULO-378 Change plural property to match other convention
Date Sat, 14 Jun 2014 04:55:38 GMT
ACCUMULO-378 Change plural property to match other convention


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/028b7800
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/028b7800
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/028b7800

Branch: refs/heads/master
Commit: 028b78000a23409070e7c973731597ea69d846bc
Parents: 5257b80
Author: Josh Elser <elserj@apache.org>
Authored: Thu Jun 5 14:47:11 2014 -0400
Committer: Josh Elser <elserj@apache.org>
Committed: Thu Jun 5 14:47:11 2014 -0400

----------------------------------------------------------------------
 .../org/apache/accumulo/core/conf/Property.java |  4 +--
 .../accumulo/master/replication/WorkMaker.java  |  4 +--
 .../master/replication/WorkMakerTest.java       |  2 +-
 .../monitor/servlets/ReplicationServlet.java    |  2 +-
 .../test/replication/CyclicReplicationIT.java   |  4 +--
 .../test/replication/ReplicationIT.java         | 12 ++++-----
 .../test/replication/ReplicationTest.java       | 26 ++++++++++----------
 .../UnorderedWorkAssignerReplicationIT.java     | 12 ++++-----
 8 files changed, 33 insertions(+), 33 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/028b7800/core/src/main/java/org/apache/accumulo/core/conf/Property.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/conf/Property.java b/core/src/main/java/org/apache/accumulo/core/conf/Property.java
index 59955f3..29993b3 100644
--- a/core/src/main/java/org/apache/accumulo/core/conf/Property.java
+++ b/core/src/main/java/org/apache/accumulo/core/conf/Property.java
@@ -430,7 +430,7 @@ public enum Property {
   TABLE_COMPACTION_STRATEGY_PREFIX("table.majc.compaction.strategy.opts.", null, PropertyType.PREFIX,
       "Properties in this category are used to configure the compaction strategy."),
   TABLE_REPLICATION("table.replication", "false", PropertyType.BOOLEAN, "Is replication enabled
for the given table"),
-  TABLE_REPLICATION_TARGETS("table.replication.target.", null, PropertyType.PREFIX, "Enumerate
a mapping of other systems which this table should " +
+  TABLE_REPLICATION_TARGET("table.replication.target.", null, PropertyType.PREFIX, "Enumerate
a mapping of other systems which this table should " +
       "replicate their data to. The key suffix is the identifying cluster name and the value
is an identifier for a location on the target system, " +
       "e.g. the ID of the table on the target to replicate to"),
 
@@ -683,7 +683,7 @@ public enum Property {
 
     return validTableProperties.contains(key) || key.startsWith(Property.TABLE_CONSTRAINT_PREFIX.getKey())
         || key.startsWith(Property.TABLE_ITERATOR_PREFIX.getKey()) || key.startsWith(Property.TABLE_LOCALITY_GROUP_PREFIX.getKey())
-        || key.startsWith(Property.TABLE_COMPACTION_STRATEGY_PREFIX.getKey()) || key.startsWith(Property.TABLE_REPLICATION_TARGETS.getKey());
+        || key.startsWith(Property.TABLE_COMPACTION_STRATEGY_PREFIX.getKey()) || key.startsWith(Property.TABLE_REPLICATION_TARGET.getKey());
   }
 
   private static final EnumSet<Property> fixedProperties = EnumSet.of(Property.TSERV_CLIENTPORT,
Property.TSERV_NATIVEMAP_ENABLED,

http://git-wip-us.apache.org/repos/asf/accumulo/blob/028b7800/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java
----------------------------------------------------------------------
diff --git a/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java
b/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java
index 68109a6..76e7621 100644
--- a/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java
+++ b/server/master/src/main/java/org/apache/accumulo/master/replication/WorkMaker.java
@@ -139,9 +139,9 @@ public class WorkMaker {
   }
 
   protected Map<String,String> getReplicationTargets(TableConfiguration tableConf)
{
-    final Map<String,String> props = tableConf.getAllPropertiesWithPrefix(Property.TABLE_REPLICATION_TARGETS);
+    final Map<String,String> props = tableConf.getAllPropertiesWithPrefix(Property.TABLE_REPLICATION_TARGET);
     final Map<String,String> targets = new HashMap<>();
-    final int propKeyLength = Property.TABLE_REPLICATION_TARGETS.getKey().length();
+    final int propKeyLength = Property.TABLE_REPLICATION_TARGET.getKey().length();
 
     for (Entry<String,String> prop : props.entrySet()) {
       targets.put(prop.getKey().substring(propKeyLength), prop.getValue());

http://git-wip-us.apache.org/repos/asf/accumulo/blob/028b7800/server/master/src/test/java/org/apache/accumulo/master/replication/WorkMakerTest.java
----------------------------------------------------------------------
diff --git a/server/master/src/test/java/org/apache/accumulo/master/replication/WorkMakerTest.java
b/server/master/src/test/java/org/apache/accumulo/master/replication/WorkMakerTest.java
index 0c4afc9..9bc3102 100644
--- a/server/master/src/test/java/org/apache/accumulo/master/replication/WorkMakerTest.java
+++ b/server/master/src/test/java/org/apache/accumulo/master/replication/WorkMakerTest.java
@@ -187,7 +187,7 @@ public class WorkMakerTest {
 
     WorkMaker workMaker = new WorkMaker(conn);
 
-    conn.tableOperations().setProperty(ReplicationTable.NAME, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "remote_cluster_1", "4");
+    conn.tableOperations().setProperty(ReplicationTable.NAME, Property.TABLE_REPLICATION_TARGET.getKey()
+ "remote_cluster_1", "4");
 
     workMaker.setBatchWriter(bw);
 

http://git-wip-us.apache.org/repos/asf/accumulo/blob/028b7800/server/monitor/src/main/java/org/apache/accumulo/monitor/servlets/ReplicationServlet.java
----------------------------------------------------------------------
diff --git a/server/monitor/src/main/java/org/apache/accumulo/monitor/servlets/ReplicationServlet.java
b/server/monitor/src/main/java/org/apache/accumulo/monitor/servlets/ReplicationServlet.java
index 9936946..69c5b55 100644
--- a/server/monitor/src/main/java/org/apache/accumulo/monitor/servlets/ReplicationServlet.java
+++ b/server/monitor/src/main/java/org/apache/accumulo/monitor/servlets/ReplicationServlet.java
@@ -121,7 +121,7 @@ public class ReplicationServlet extends BasicServlet {
       }
     }
 
-    final String targetPrefix = Property.TABLE_REPLICATION_TARGETS.getKey();
+    final String targetPrefix = Property.TABLE_REPLICATION_TARGET.getKey();
 
     // The total set of configured targets
     Set<ReplicationTarget> allConfiguredTargets = new HashSet<>();

http://git-wip-us.apache.org/repos/asf/accumulo/blob/028b7800/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java
b/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java
index a75113b..c84e53d 100644
--- a/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java
@@ -154,12 +154,12 @@ public class CyclicReplicationIT {
       // Replicate master1 in the master1 cluster to master2 in the master2 cluster
       connMaster1.tableOperations().setProperty(master1Table, Property.TABLE_REPLICATION.getKey(),
"true");
       connMaster1.tableOperations().setProperty(master1Table,
-          Property.TABLE_REPLICATION_TARGETS.getKey() + master2Cluster.getInstanceName(),
master2TableId);
+          Property.TABLE_REPLICATION_TARGET.getKey() + master2Cluster.getInstanceName(),
master2TableId);
 
       // Replicate master2 in the master2 cluster to master1 in the master2 cluster
       connMaster2.tableOperations().setProperty(master2Table, Property.TABLE_REPLICATION.getKey(),
"true");
       connMaster2.tableOperations().setProperty(master2Table,
-          Property.TABLE_REPLICATION_TARGETS.getKey() + master1Cluster.getInstanceName(),
master1TableId);
+          Property.TABLE_REPLICATION_TARGET.getKey() + master1Cluster.getInstanceName(),
master1TableId);
 
       // Give our replication user the ability to write to the respective table
       connMaster1.securityOperations().grantTablePermission(master1UserName, master1Table,
TablePermission.WRITE);

http://git-wip-us.apache.org/repos/asf/accumulo/blob/028b7800/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java
index d051e75..2af81f6 100644
--- a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java
@@ -145,7 +145,7 @@ public class ReplicationIT extends ConfigurableMacIT {
   
       // Replicate this table to the peerClusterName in a table with the peerTableId table
id
       connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId);
+      connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId);
   
       // Write some data to table1
       BatchWriter bw = connMaster.createBatchWriter(masterTable, new BatchWriterConfig());
@@ -315,10 +315,10 @@ public class ReplicationIT extends ConfigurableMacIT {
 
       // Replicate this table to the peerClusterName in a table with the peerTableId table
id
       connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId1);
+      connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId1);
 
       connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId2);
+      connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId2);
 
       // Write some data to table1
       BatchWriter bw = connMaster.createBatchWriter(masterTable1, new BatchWriterConfig());
@@ -453,7 +453,7 @@ public class ReplicationIT extends ConfigurableMacIT {
 
     // Replicate this table to the peerClusterName in a table with the peerTableId table
id
     connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION.getKey(),
"true");
-    connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId);
+    connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId);
 
     // Write some data to table1
     BatchWriter bw = connMaster.createBatchWriter(masterTable, new BatchWriterConfig());
@@ -562,10 +562,10 @@ public class ReplicationIT extends ConfigurableMacIT {
 
       // Replicate this table to the peerClusterName in a table with the peerTableId table
id
       connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId1);
+      connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId1);
 
       connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId2);
+      connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId2);
 
       // Write some data to table1
       BatchWriter bw = connMaster.createBatchWriter(masterTable1, new BatchWriterConfig());

http://git-wip-us.apache.org/repos/asf/accumulo/blob/028b7800/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java
b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java
index 8554950..7ea4c84 100644
--- a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java
+++ b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java
@@ -401,7 +401,7 @@ public class ReplicationTest extends ConfigurableMacIT {
 
     conn.tableOperations().create(table1);
     conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION.getKey(), "true");
-    conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+    conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
     Thread.sleep(1000);
 
     // Write some data to table1
@@ -419,7 +419,7 @@ public class ReplicationTest extends ConfigurableMacIT {
 
     conn.tableOperations().create(table2);
     conn.tableOperations().setProperty(table2, Property.TABLE_REPLICATION.getKey(), "true");
-    conn.tableOperations().setProperty(table2, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+    conn.tableOperations().setProperty(table2, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
     Thread.sleep(1000);
 
     // Write some data to table2
@@ -437,7 +437,7 @@ public class ReplicationTest extends ConfigurableMacIT {
 
     conn.tableOperations().create(table3);
     conn.tableOperations().setProperty(table3, Property.TABLE_REPLICATION.getKey(), "true");
-    conn.tableOperations().setProperty(table3, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+    conn.tableOperations().setProperty(table3, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
     Thread.sleep(1000);
 
     // Write some data to table3
@@ -564,13 +564,13 @@ public class ReplicationTest extends ConfigurableMacIT {
 
     conn.tableOperations().create(table1);
     conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION.getKey(), "true");
-    conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+    conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
     conn.tableOperations().create(table2);
     conn.tableOperations().setProperty(table2, Property.TABLE_REPLICATION.getKey(), "true");
-    conn.tableOperations().setProperty(table2, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+    conn.tableOperations().setProperty(table2, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
     conn.tableOperations().create(table3);
     conn.tableOperations().setProperty(table3, Property.TABLE_REPLICATION.getKey(), "true");
-    conn.tableOperations().setProperty(table3, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+    conn.tableOperations().setProperty(table3, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
 
     // Write some data to table1
     BatchWriter bw = conn.createBatchWriter(table1, new BatchWriterConfig());
@@ -637,7 +637,7 @@ public class ReplicationTest extends ConfigurableMacIT {
     Assert.assertNotNull(tableId);
 
     conn.tableOperations().setProperty(table, Property.TABLE_REPLICATION.getKey(), "true");
-    conn.tableOperations().setProperty(table, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+    conn.tableOperations().setProperty(table, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
     // just sleep
     conn.instanceOperations().setProperty(Property.REPLICATION_PEERS.getKey() + "cluster1",
         ReplicaSystemFactory.getPeerConfigurationValue(MockReplicaSystem.class, "50000"));
@@ -762,7 +762,7 @@ public class ReplicationTest extends ConfigurableMacIT {
         // Enable replication on table1
         conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION.getKey(), "true");
         // Replicate table1 to cluster1 in the table with id of '4'
-        conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "4");
+        conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "4");
         conn.instanceOperations().setProperty(Property.REPLICATION_PEERS.getKey() + "cluster1",
             ReplicaSystemFactory.getPeerConfigurationValue(MockReplicaSystem.class, "100000"));
         break;
@@ -931,7 +931,7 @@ public class ReplicationTest extends ConfigurableMacIT {
         // Enable replication on table1
         conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION.getKey(), "true");
         // Replicate table1 to cluster1 in the table with id of '4'
-        conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "4");
+        conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "4");
         attempts = 0;
       } catch (Exception e) {
         attempts--;
@@ -1049,7 +1049,7 @@ public class ReplicationTest extends ConfigurableMacIT {
     try {
       conn.tableOperations().create(table1);
       conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION.getKey(), "true");
-      conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+      conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
       conn.instanceOperations().setProperty(Property.REPLICATION_PEERS.getKey() + "cluster1",
           ReplicaSystemFactory.getPeerConfigurationValue(MockReplicaSystem.class, null));
 
@@ -1068,7 +1068,7 @@ public class ReplicationTest extends ConfigurableMacIT {
 
       conn.tableOperations().create(table2);
       conn.tableOperations().setProperty(table2, Property.TABLE_REPLICATION.getKey(), "true");
-      conn.tableOperations().setProperty(table2, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+      conn.tableOperations().setProperty(table2, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
 
       // Write some data to table2
       bw = conn.createBatchWriter(table2, new BatchWriterConfig());
@@ -1085,7 +1085,7 @@ public class ReplicationTest extends ConfigurableMacIT {
 
       conn.tableOperations().create(table3);
       conn.tableOperations().setProperty(table3, Property.TABLE_REPLICATION.getKey(), "true");
-      conn.tableOperations().setProperty(table3, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "1");
+      conn.tableOperations().setProperty(table3, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "1");
 
       // Write some data to table3
       bw = conn.createBatchWriter(table3, new BatchWriterConfig());
@@ -1235,7 +1235,7 @@ public class ReplicationTest extends ConfigurableMacIT {
           // Enable replication on table1
           conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION.getKey(),
"true");
           // Replicate table1 to cluster1 in the table with id of '4'
-          conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ "cluster1", "4");
+          conn.tableOperations().setProperty(table1, Property.TABLE_REPLICATION_TARGET.getKey()
+ "cluster1", "4");
           // Use the MockReplicaSystem impl and sleep for 5seconds
           conn.instanceOperations().setProperty(Property.REPLICATION_PEERS.getKey() + "cluster1",
               ReplicaSystemFactory.getPeerConfigurationValue(MockReplicaSystem.class, "1000"));

http://git-wip-us.apache.org/repos/asf/accumulo/blob/028b7800/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java
b/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java
index b90d7f7..558c75f 100644
--- a/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java
@@ -145,7 +145,7 @@ public class UnorderedWorkAssignerReplicationIT extends ConfigurableMacIT
{
 
       // Replicate this table to the peerClusterName in a table with the peerTableId table
id
       connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId);
+      connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId);
 
       // Write some data to table1
       BatchWriter bw = connMaster.createBatchWriter(masterTable, new BatchWriterConfig());
@@ -306,10 +306,10 @@ public class UnorderedWorkAssignerReplicationIT extends ConfigurableMacIT
{
 
       // Replicate this table to the peerClusterName in a table with the peerTableId table
id
       connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId1);
+      connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId1);
 
       connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId2);
+      connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId2);
 
       // Write some data to table1
       BatchWriter bw = connMaster.createBatchWriter(masterTable1, new BatchWriterConfig());
@@ -459,7 +459,7 @@ public class UnorderedWorkAssignerReplicationIT extends ConfigurableMacIT
{
 
     // Replicate this table to the peerClusterName in a table with the peerTableId table
id
     connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION.getKey(),
"true");
-    connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId);
+    connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId);
 
     // Write some data to table1
     BatchWriter bw = connMaster.createBatchWriter(masterTable, new BatchWriterConfig());
@@ -568,10 +568,10 @@ public class UnorderedWorkAssignerReplicationIT extends ConfigurableMacIT
{
 
       // Replicate this table to the peerClusterName in a table with the peerTableId table
id
       connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId1);
+      connMaster.tableOperations().setProperty(masterTable1, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId1);
 
       connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION.getKey(),
"true");
-      connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGETS.getKey()
+ peerClusterName, peerTableId2);
+      connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGET.getKey()
+ peerClusterName, peerTableId2);
 
       // Write some data to table1
       BatchWriter bw = connMaster.createBatchWriter(masterTable1, new BatchWriterConfig());


Mime
View raw message