commit 09342706b029b9943a2d2d201b37663060eeb3d8
author Madan Jampani <madan@onlab.us> Thu Feb 05 23:32:40 2015 -0800
committer Jonathan Hart <jono@onlab.us> Wed Feb 11 05:26:26 2015 +0000
tree fbc1b29efd2db2c4a9aaf1951bf026c2e0d38847
parent 89bf6fb1f3300bad0bc6c631e5b1e0b03b060dd8

WIP: Consistent map implementation.

Change-Id: I51b2d954b7a8ff2c51c425d9a8125937d4eaa6b0

Change-Id: Ib27799d4eb60fc4bfaa8d2f21a904365ff5437eb

Change-Id: I95c937600ceb8f282a482280217671c471f40b9c

core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabaseManager.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabaseManager.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabaseManager.java
index 44cd3a1..81f00de 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabaseManager.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabaseManager.java
@@ -10,6 +10,9 @@
 import net.kuujo.copycat.cluster.internal.coordinator.DefaultClusterCoordinator;
 import net.kuujo.copycat.util.concurrent.NamedThreadFactory;
 
+/**
+ * Manages a PartitionedDatabase.
+ */
 public interface PartitionedDatabaseManager {
     /**
      * Opens the database.
@@ -73,7 +76,7 @@
                         .withDefaultSerializer(copycatConfig.getDefaultSerializer().copy())
                         .withDefaultExecutor(copycatConfig.getDefaultExecutor()))));
         partitionedDatabase.setPartitioner(
-                new SimpleKeyHashPartitioner<>(partitionedDatabase.getRegisteredPartitions()));
+                new SimpleKeyHashPartitioner(partitionedDatabase.getRegisteredPartitions()));
         return partitionedDatabase;
     }
 }