Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
DefaultBlockMaster.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultBlockMaster.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
List<Journal.JournalEntry> |
FileSystemJournalEntryMerger.getMergedJournalEntries() |
static List<Journal.JournalEntry> |
InodeSyncStream.mergeCreateComplete(List<Journal.JournalEntry> entries)
Merge inode entry with subsequent update inode and update inode file entries.
|
Modifier and Type | Method and Description |
---|---|
void |
FileSystemJournalEntryMerger.add(Journal.JournalEntry entry)
Adds a new journal entry and merges it on the fly.
|
void |
RpcContext.journal(Journal.JournalEntry entry)
Syntax sugar for getJournalContext().append(entry).
|
Modifier and Type | Method and Description |
---|---|
static List<Journal.JournalEntry> |
InodeSyncStream.mergeCreateComplete(List<Journal.JournalEntry> entries)
Merge inode entry with subsequent update inode and update inode file entries.
|
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
ActiveSyncManager.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
ActiveSyncManager.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
InodeTreeBufferedIterator.next() |
Journal.JournalEntry |
MutableInodeFile.toJournalEntry() |
Journal.JournalEntry |
MutableInodeDirectory.toJournalEntry() |
Journal.JournalEntry |
Inode.toJournalEntry() |
Journal.JournalEntry |
MutableInodeFile.toJournalEntry(String path) |
Journal.JournalEntry |
MutableInodeDirectory.toJournalEntry(String path) |
abstract Journal.JournalEntry |
MutableInode.toJournalEntry(String path) |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<Journal.JournalEntry> |
InodeTreeBufferedIterator.create(InodeStore inodeStore,
InodeDirectory rootInode)
Creates buffered iterator with closeable interface.
|
CloseableIterator<Journal.JournalEntry> |
InodeDirectoryIdGenerator.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
InodeTreePersistentState.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
MountTable.State.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
InodeDirectoryIdGenerator.processJournalEntry(Journal.JournalEntry entry) |
boolean |
InodeTreePersistentState.processJournalEntry(Journal.JournalEntry entry) |
boolean |
MountTable.State.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
LoadJob.toJournalEntry() |
Modifier and Type | Method and Description |
---|---|
static JobFactory |
JobFactoryProducer.create(Journal.JournalEntry entry,
FileSystemMaster fsMaster) |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
JournalReader.getEntry()
Returns the next entry in the journal.
|
Journal.JournalEntry |
JournalFileParser.next()
Parses a journal file and returns the next entry from the journal file.
|
Journal.JournalEntry |
JournalEntryStreamReader.readEntry()
Reads a journal entry from the input stream.
|
Journal.JournalEntry |
JournalEntryRepresentable.toJournalEntry() |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
JournaledGroup.getJournalEntryIterator() |
default CloseableIterator<Journal.JournalEntry> |
DelegatingJournaled.getJournalEntryIterator() |
default CloseableIterator<Journal.JournalEntry> |
NoopJournaled.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
JournalEntryIterable.getJournalEntryIterator() |
List<Journal.JournalEntry> |
JournalEntryMerger.getMergedJournalEntries()
Returns a list of journal entries which have been merged.
|
Modifier and Type | Method and Description |
---|---|
void |
JournalEntryMerger.add(Journal.JournalEntry entry)
Adds a new journal entry.
|
void |
MasterJournalContext.append(Journal.JournalEntry entry) |
void |
MergeJournalContext.append(Journal.JournalEntry entry) |
void |
NoopJournalContext.append(Journal.JournalEntry entry) |
void |
FileSystemMergeJournalContext.append(Journal.JournalEntry entry)
Adds the new journal entry into the journal entry merger.
|
void |
JournalContext.append(Journal.JournalEntry entry) |
void |
StateChangeJournalContext.append(Journal.JournalEntry entry) |
long |
AsyncJournalWriter.appendEntry(Journal.JournalEntry entry)
Appends a
Journal.JournalEntry for writing to the journal. |
default void |
DelegatingJournaled.applyAndJournal(java.util.function.Supplier<JournalContext> context,
Journal.JournalEntry entry) |
default void |
Journaled.applyAndJournal(java.util.function.Supplier<JournalContext> context,
Journal.JournalEntry entry)
Applies and journals a journal entry.
|
static String |
JournalEntryAssociation.getMasterForEntry(Journal.JournalEntry entry) |
boolean |
JournaledGroup.processJournalEntry(Journal.JournalEntry entry) |
default boolean |
DelegatingJournaled.processJournalEntry(Journal.JournalEntry entry) |
default boolean |
NoopJournaled.processJournalEntry(Journal.JournalEntry entry) |
boolean |
Journaled.processJournalEntry(Journal.JournalEntry entry)
Attempts to apply a journal entry.
|
static void |
JournalUtils.sinkAppend(java.util.function.Supplier<Set<JournalSink>> journalSinks,
Journal.JournalEntry entry)
Appends a journal entry to all the supplied journal sinks.
|
void |
JournalWriter.write(Journal.JournalEntry entry)
Writes an entry.
|
Constructor and Description |
---|
MergeJournalContext(JournalContext journalContext,
AlluxioURI uri,
java.util.function.UnaryOperator<List<Journal.JournalEntry>> merger)
Constructs a
MergeJournalContext . |
Modifier and Type | Method and Description |
---|---|
Optional<Journal.JournalEntry> |
JournalCheckpointFormat.JournalCheckpointReader.nextEntry() |
Modifier and Type | Method and Description |
---|---|
void |
BufferedJournalApplier.processJournalEntry(Journal.JournalEntry journalEntry)
Processes given journal entry for applying.
|
void |
RaftJournalWriter.write(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
default void |
JournalSink.append(Journal.JournalEntry entry)
Appends a new journal entry written to the journal.
|
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
UfsJournalReader.getEntry() |
Journal.JournalEntry |
UfsJournalFileParser.next() |
Modifier and Type | Method and Description |
---|---|
void |
UfsJournalLogWriter.write(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
JournalInputStream.read()
Reads the next journal entry.
|
Journal.JournalEntry |
JournalEntryRepresentable.toJournalEntry() |
Modifier and Type | Method and Description |
---|---|
long |
AsyncJournalWriter.appendEntry(Journal.JournalEntry entry)
Appends a
Journal.JournalEntry for writing to the journal. |
void |
JournalFormatter.serialize(Journal.JournalEntry entry,
OutputStream outputStream)
Serializes the given entry and writes it to the given output stream.
|
void |
ProtoBufJournalFormatter.serialize(Journal.JournalEntry entry,
OutputStream outputStream) |
void |
JournalOutputStream.write(Journal.JournalEntry entry)
Writes a
Journal.JournalEntry to the journal. |
void |
JournalWriter.write(Journal.JournalEntry entry)
Writes an entry to the current log stream.
|
Modifier and Type | Method and Description |
---|---|
void |
UfsJournalWriter.write(Journal.JournalEntry entry) |
void |
UfsJournalWriter.EntryOutputStream.write(Journal.JournalEntry entry)
The given entry should not have its sequence number set.
|
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
PathProperties.State.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
DefaultMetaMaster.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
DefaultMetaMaster.State.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
PathProperties.State.processJournalEntry(Journal.JournalEntry entry) |
boolean |
DefaultMetaMaster.processJournalEntry(Journal.JournalEntry entry) |
boolean |
DefaultMetaMaster.State.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
JournaledJobMetaStore.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
JournaledJobMetaStore.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
AlluxioCatalog.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
Database.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
void |
Database.applyAndJournal(java.util.function.Supplier<JournalContext> context,
Journal.JournalEntry entry) |
boolean |
AlluxioCatalog.processJournalEntry(Journal.JournalEntry entry) |
boolean |
Database.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<Journal.JournalEntry> |
Journal.JournalEntry.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
Journal.JournalEntry.Builder.build() |
Journal.JournalEntry |
Journal.JournalEntry.Builder.buildPartial() |
static Journal.JournalEntry |
Journal.JournalEntry.getDefaultInstance() |
Journal.JournalEntry |
Journal.JournalEntry.getDefaultInstanceForType() |
Journal.JournalEntry |
Journal.JournalEntry.Builder.getDefaultInstanceForType() |
Journal.JournalEntry |
Journal.JournalEntryOrBuilder.getJournalEntries(int index)
This journal entry is a list of other entries.
|
Journal.JournalEntry |
Journal.JournalEntry.getJournalEntries(int index)
This journal entry is a list of other entries.
|
Journal.JournalEntry |
Journal.JournalEntry.Builder.getJournalEntries(int index)
This journal entry is a list of other entries.
|
static Journal.JournalEntry |
Journal.JournalEntry.parseDelimitedFrom(InputStream input) |
static Journal.JournalEntry |
Journal.JournalEntry.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(byte[] data) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(ByteBuffer data) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(com.google.protobuf.ByteString data) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(com.google.protobuf.CodedInputStream input) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(InputStream input) |
static Journal.JournalEntry |
Journal.JournalEntry.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<Journal.JournalEntry> |
Journal.JournalEntryOrBuilder.getJournalEntriesList()
This journal entry is a list of other entries.
|
List<Journal.JournalEntry> |
Journal.JournalEntry.getJournalEntriesList()
This journal entry is a list of other entries.
|
List<Journal.JournalEntry> |
Journal.JournalEntry.Builder.getJournalEntriesList()
This journal entry is a list of other entries.
|
com.google.protobuf.Parser<Journal.JournalEntry> |
Journal.JournalEntry.getParserForType() |
static com.google.protobuf.Parser<Journal.JournalEntry> |
Journal.JournalEntry.parser() |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry.Builder |
Journal.JournalEntry.Builder.addJournalEntries(int index,
Journal.JournalEntry value)
This journal entry is a list of other entries.
|
Journal.JournalEntry.Builder |
Journal.JournalEntry.Builder.addJournalEntries(Journal.JournalEntry value)
This journal entry is a list of other entries.
|
Journal.JournalEntry.Builder |
Journal.JournalEntry.Builder.mergeFrom(Journal.JournalEntry other) |
static Journal.JournalEntry.Builder |
Journal.JournalEntry.newBuilder(Journal.JournalEntry prototype) |
Journal.JournalEntry.Builder |
Journal.JournalEntry.Builder.setJournalEntries(int index,
Journal.JournalEntry value)
This journal entry is a list of other entries.
|
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry.Builder |
Journal.JournalEntry.Builder.addAllJournalEntries(Iterable<? extends Journal.JournalEntry> values)
This journal entry is a list of other entries.
|
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
Job.toJournalEntry() |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
MasterUfsManager.getJournalEntryIterator() |
Copyright © 2023. All Rights Reserved.