Package | Description |
---|---|
alluxio.master.journal | |
alluxio.master.journal.noop | |
alluxio.master.journal.raft | |
alluxio.master.journal.ufs |
Modifier and Type | Method and Description |
---|---|
Set<JournalSink> |
JournalSystem.getJournalSinks(Master master) |
Set<JournalSink> |
AbstractJournalSystem.getJournalSinks(Master master) |
Modifier and Type | Method and Description |
---|---|
void |
JournalSystem.addJournalSink(Master master,
JournalSink journalSink) |
void |
AbstractJournalSystem.addJournalSink(Master master,
JournalSink journalSink) |
void |
JournalSystem.removeJournalSink(Master master,
JournalSink journalSink) |
void |
AbstractJournalSystem.removeJournalSink(Master master,
JournalSink journalSink) |
Modifier and Type | Method and Description |
---|---|
static void |
JournalUtils.sinkAppend(java.util.function.Supplier<Set<JournalSink>> journalSinks,
Journal.JournalEntry entry)
Appends a journal entry to all the supplied journal sinks.
|
static void |
JournalUtils.sinkFlush(java.util.function.Supplier<Set<JournalSink>> journalSinks)
Appends a flush to all the supplied journal sinks.
|
Constructor and Description |
---|
AsyncJournalWriter(JournalWriter journalWriter,
java.util.function.Supplier<Set<JournalSink>> journalSinks)
Creates a
AsyncJournalWriter . |
AsyncJournalWriter(JournalWriter journalWriter,
java.util.function.Supplier<Set<JournalSink>> journalSinks,
String journalName)
Creates a
AsyncJournalWriter . |
Modifier and Type | Method and Description |
---|---|
Set<JournalSink> |
NoopJournalSystem.getJournalSinks(Master master) |
Modifier and Type | Method and Description |
---|---|
void |
NoopJournalSystem.addJournalSink(Master master,
JournalSink journalSink) |
void |
NoopJournalSystem.removeJournalSink(Master master,
JournalSink journalSink) |
Constructor and Description |
---|
BufferedJournalApplier(Map<String,RaftJournal> journals,
java.util.function.Supplier<Set<JournalSink>> journalSinks)
Creates a buffered applier over given journals.
|
Constructor and Description |
---|
UfsJournal(URI location,
Master master,
long quietPeriodMs,
java.util.function.Supplier<Set<JournalSink>> journalSinks)
Creates a new instance of
UfsJournal . |
UfsJournalCheckpointThread(Master master,
UfsJournal journal,
long startSequence,
java.util.function.Supplier<Set<JournalSink>> journalSinks)
Creates a new instance of
UfsJournalCheckpointThread . |
UfsJournalCheckpointThread(Master master,
UfsJournal journal,
java.util.function.Supplier<Set<JournalSink>> journalSinks)
Creates a new instance of
UfsJournalCheckpointThread . |
Copyright © 2023. All Rights Reserved.