Rename LogCompactor to Compactor.

atomix · May 31, 2015 · 8298843 · 8298843
1 parent 9006d9e
commit 8298843
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/.../kuujo/copycat/raft/log/LogCompactor.java → ...net/kuujo/copycat/raft/log/Compactor.java b/.../kuujo/copycat/raft/log/LogCompactor.java → ...net/kuujo/copycat/raft/log/Compactor.java
@@ -28,8 +28,8 @@
  *
  * @author <a href="http://github.com/kuujo">Jordan Halterman</a>
  */
-public class LogCompactor implements Runnable, AutoCloseable {
+public class Compactor implements Runnable, AutoCloseable {
-  private static final Logger LOGGER = LoggerFactory.getLogger(LogCompactor.class);
+  private static final Logger LOGGER = LoggerFactory.getLogger(Compactor.class);
   private static final int DEFAULT_COMPACTION_FACTOR = 10;
   private static final long DEFAULT_COMPACTION_INTERVAL = TimeUnit.HOURS.toMillis(1);
   private static final long COMPACT_INTERVAL = 60 * 1000;
@@ -45,7 +45,7 @@ public class LogCompactor implements Runnable, AutoCloseable {
   private long previousCompaction;
   private ScheduledFuture<?> future;
 
-  public LogCompactor(Log log, EntryFilter filter, ExecutionContext context) {
+  public Compactor(Log log, EntryFilter filter, ExecutionContext context) {
     this.log = log;
     this.filter = filter;
     this.context = context;
@@ -77,7 +77,7 @@ public int getCompactionFactor() {
    * @param compactionFactor The compaction factor.
    * @return The log compactor.
    */
-  public LogCompactor withCompactionFactor(int compactionFactor) {
+  public Compactor withCompactionFactor(int compactionFactor) {
     setCompactionFactor(compactionFactor);
     return this;
   }
@@ -108,7 +108,7 @@ public long getCompactionInterval() {
    * @param compactionInterval The interval at which major compaction is run.
    * @return The log compactor.
    */
-  public LogCompactor withCompactionInterval(long compactionInterval) {
+  public Compactor withCompactionInterval(long compactionInterval) {
     setCompactionInterval(compactionInterval);
     return this;
   }

diff --git a/raft/src/main/java/net/kuujo/copycat/raft/state/RaftContext.java b/raft/src/main/java/net/kuujo/copycat/raft/state/RaftContext.java
@@ -22,8 +22,8 @@
 import net.kuujo.copycat.raft.Command;
 import net.kuujo.copycat.raft.Query;
 import net.kuujo.copycat.raft.StateMachine;
+import net.kuujo.copycat.raft.log.Compactor;
 import net.kuujo.copycat.raft.log.Log;
-import net.kuujo.copycat.raft.log.LogCompactor;
 import net.kuujo.copycat.raft.rpc.CommandRequest;
 import net.kuujo.copycat.raft.rpc.QueryRequest;
 import net.kuujo.copycat.raft.rpc.Response;
@@ -51,7 +51,7 @@ public class RaftContext implements Managed<RaftContext> {
   private final Set<EventListener<Member>> electionListeners = new CopyOnWriteArraySet<>();
   private final RaftStateMachine stateMachine;
   private final Log log;
-  private final LogCompactor compactor;
+  private final Compactor compactor;
   private final ManagedCluster cluster;
   private final String topic;
   private final ExecutionContext context;
@@ -76,7 +76,7 @@ public class RaftContext implements Managed<RaftContext> {
   public RaftContext(Log log, StateMachine stateMachine, ManagedCluster cluster, String topic, ExecutionContext context) {
     this.log = log;
     this.stateMachine = new RaftStateMachine(stateMachine);
-    this.compactor = new LogCompactor(log, this.stateMachine::filter, context);
+    this.compactor = new Compactor(log, this.stateMachine::filter, context);
     this.cluster = cluster;
     this.topic = topic;
     this.context = context;
@@ -530,7 +530,7 @@ public Log getLog() {
    *
    * @return The log compactor.
    */
-  public LogCompactor getCompactor() {
+  public Compactor getCompactor() {
     return compactor;
   }