@NotThreadSafe public interface JournalReader extends Closeable
Modifier and Type | Interface and Description |
---|---|
static class |
JournalReader.State
States that the reader can be after calling
advance() . |
Modifier and Type | Method and Description |
---|---|
JournalReader.State |
advance()
Advances the reader to the next element.
|
CheckpointInputStream |
getCheckpoint()
Returns the input stream for reading a checkpoint.
|
Journal.JournalEntry |
getEntry()
Returns the next entry in the journal.
|
long |
getNextSequenceNumber()
Gets the the sequence number of the next journal log entry to read.
|
Journal.JournalEntry getEntry()
advance()
returned JournalReader.State.LOG
.
Multiple calls to getEntry without calling advance will return the same entry.CheckpointInputStream getCheckpoint()
advance()
returned JournalReader.State.CHECKPOINT
.
Multiple calls to getCheckpoint without calling advance will return the same stream.long getNextSequenceNumber()
JournalReader.State advance() throws IOException
JournalReader.State
IOException
Copyright © 2023. All Rights Reserved.