Separate out RaftEntryMeta

[controller.git] / atomix-storage / src / main / java / io / atomix / storage / journal / SegmentedJournal.java

diff --git a/atomix-storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java b/atomix-storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
index 501e650dc59baa28a5db15f2964eebc6a1e903b3..a3cb3ad29c68ae68f09a80118fcc1570d6657c00 100644 (file)
--- a/atomix-storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
+++ b/atomix-storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
@@ -20,16 +20,19 @@ import static java.util.Objects.requireNonNull;
 
 import com.google.common.base.MoreObjects;
 import org.eclipse.jdt.annotation.NonNull;
+import org.opendaylight.controller.raft.journal.FromByteBufMapper;
+import org.opendaylight.controller.raft.journal.RaftJournal;
+import org.opendaylight.controller.raft.journal.ToByteBufMapper;
 
 /**
- * A {@link Journal} implementation based on a {@link ByteBufJournal}.
+ * A {@link Journal} implementation based on a {@link RaftJournal}.
  */
 public final class SegmentedJournal<E> implements Journal<E> {
     private final @NonNull SegmentedJournalWriter<E> writer;
     private final @NonNull FromByteBufMapper<E> readMapper;
-    private final @NonNull ByteBufJournal journal;
+    private final @NonNull RaftJournal journal;
 
-    public SegmentedJournal(final ByteBufJournal journal, final FromByteBufMapper<E> readMapper,
+    public SegmentedJournal(final RaftJournal journal, final FromByteBufMapper<E> readMapper,
             final ToByteBufMapper<E> writeMapper) {
         this.journal = requireNonNull(journal, "journal is required");
         this.readMapper = requireNonNull(readMapper, "readMapper cannot be null");