@NotThreadSafe public static final class DefaultMetaMaster.State extends java.lang.Object implements Journaled
| Constructor and Description |
|---|
State() |
| Modifier and Type | Method and Description |
|---|---|
void |
applyAndJournal(java.util.function.Supplier<JournalContext> ctx,
java.lang.String clusterId) |
CheckpointName |
getCheckpointName() |
java.lang.String |
getClusterID() |
CloseableIterator<Journal.JournalEntry> |
getJournalEntryIterator() |
boolean |
processJournalEntry(Journal.JournalEntry entry) |
void |
resetState() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitapplyAndJournal, restoreFromCheckpoint, writeToCheckpointpublic java.lang.String getClusterID()
public CheckpointName getCheckpointName()
getCheckpointName in interface Checkpointedpublic boolean processJournalEntry(Journal.JournalEntry entry)
processJournalEntry in interface Journaledpublic void applyAndJournal(java.util.function.Supplier<JournalContext> ctx, java.lang.String clusterId)
ctx - the journal contextclusterId - the clusterId journal clusterIdpublic void resetState()
resetState in interface Journaledpublic CloseableIterator<Journal.JournalEntry> getJournalEntryIterator()
getJournalEntryIterator in interface JournalEntryIterableCopyright © 2020. All Rights Reserved.