fixes #860 spelled partition corectly
diff --git a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ParitionManager.java b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionManager.java
similarity index 98%
rename from modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ParitionManager.java
rename to modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionManager.java
index 3ebb01e..f0e6305 100644
--- a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ParitionManager.java
+++ b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionManager.java
@@ -67,9 +67,9 @@
* notifications. This limitation is important for scaling, even if there are 1,000 workers there
* will never be more than 7 to 13 workers scanning a portion of the table.
*/
-public class ParitionManager {
+public class PartitionManager {
- private static final Logger log = LoggerFactory.getLogger(ParitionManager.class);
+ private static final Logger log = LoggerFactory.getLogger(PartitionManager.class);
private final PathChildrenCache childrenCache;
private final PersistentEphemeralNode myESNode;
@@ -267,7 +267,7 @@
}
}
- ParitionManager(Environment env, long minSleepTime, long maxSleepTime) {
+ PartitionManager(Environment env, long minSleepTime, long maxSleepTime) {
try {
this.curator = env.getSharedResources().getCurator();
this.env = env;
diff --git a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionNotificationFinder.java b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionNotificationFinder.java
index c940850..c3649aa 100644
--- a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionNotificationFinder.java
+++ b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionNotificationFinder.java
@@ -26,7 +26,7 @@
public class PartitionNotificationFinder implements NotificationFinder {
- private ParitionManager paritionManager;
+ private PartitionManager partitionManager;
private Thread scanThread;
private NotificationProcessor processor;
private Environment env;
@@ -49,10 +49,10 @@
env.getConfiguration().getInt(FluoConfigurationImpl.NTFY_FINDER_MAX_SLEEP_TIME_PROP,
FluoConfigurationImpl.NTFY_FINDER_MAX_SLEEP_TIME_DEFAULT);
- paritionManager = new ParitionManager(env, minSleepTime, maxSleepTime);
+ partitionManager = new PartitionManager(env, minSleepTime, maxSleepTime);
scanThread =
- new Thread(new ScanTask(this, processor, paritionManager, env, stopped, minSleepTime,
+ new Thread(new ScanTask(this, processor, partitionManager, env, stopped, minSleepTime,
maxSleepTime));
scanThread.setName(getClass().getSimpleName() + " " + ScanTask.class.getSimpleName());
scanThread.setDaemon(true);
@@ -70,12 +70,12 @@
throw new RuntimeException(e);
}
- paritionManager.stop();
+ partitionManager.stop();
}
@Override
public boolean shouldProcess(Notification notification) {
- return paritionManager.shouldProcess(notification);
+ return partitionManager.shouldProcess(notification);
}
@Override
diff --git a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
index 35f3215..3ebc625 100644
--- a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
+++ b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
@@ -47,7 +47,7 @@
private static final Logger log = LoggerFactory.getLogger(ScanTask.class);
private final NotificationFinder finder;
- private final ParitionManager partitionManager;
+ private final PartitionManager partitionManager;
private final NotificationProcessor proccessor;
private final Random rand = new Random();
private final AtomicBoolean stopped;
@@ -58,7 +58,7 @@
private long maxSleepTime;
ScanTask(NotificationFinder finder, NotificationProcessor proccessor,
- ParitionManager partitionManager, Environment env, AtomicBoolean stopped, long minSleepTime,
+ PartitionManager partitionManager, Environment env, AtomicBoolean stopped, long minSleepTime,
long maxSleepTime) {
this.finder = finder;
this.rangeData = new HashMap<>();
diff --git a/modules/core/src/test/java/org/apache/fluo/core/worker/finder/hash/HashTest.java b/modules/core/src/test/java/org/apache/fluo/core/worker/finder/hash/HashTest.java
index b3496dd..1d1c5a6 100644
--- a/modules/core/src/test/java/org/apache/fluo/core/worker/finder/hash/HashTest.java
+++ b/modules/core/src/test/java/org/apache/fluo/core/worker/finder/hash/HashTest.java
@@ -63,7 +63,7 @@
byte[] cfcq = NotificationUtil.encodeCol(col);
Key k = new Key(row, ColumnConstants.NOTIFY_CF.toArray(), cfcq, new byte[0], 6);
boolean accept = NotificationHashFilter.accept(k, 7, 3);
- Assert.assertEquals(accept, ParitionManager.shouldProcess(Notification.from(k), 7, 3));
+ Assert.assertEquals(accept, PartitionManager.shouldProcess(Notification.from(k), 7, 3));
return accept;
}
}
diff --git a/modules/core/src/test/java/org/apache/fluo/core/worker/finder/hash/PartitionManagerTest.java b/modules/core/src/test/java/org/apache/fluo/core/worker/finder/hash/PartitionManagerTest.java
index 8a02edc..b3d0d64 100644
--- a/modules/core/src/test/java/org/apache/fluo/core/worker/finder/hash/PartitionManagerTest.java
+++ b/modules/core/src/test/java/org/apache/fluo/core/worker/finder/hash/PartitionManagerTest.java
@@ -59,7 +59,7 @@
for (int i = 0; i < numWorkers; i++) {
String me = nff.apply(i);
- PartitionInfo pi = ParitionManager.getGroupInfo(me, children, tablets, groupSize);
+ PartitionInfo pi = PartitionManager.getGroupInfo(me, children, tablets, groupSize);
Assert.assertEquals(expectedGroups, pi.getNumGroups());
Assert.assertTrue(pi.getMyGroupSize() >= Math.min(numWorkers, groupSize)
&& pi.getMyGroupSize() <= maxGroupSize);
