Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
NoopMaster.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
void |
NoopMaster.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
DefaultBlockMaster.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultBlockMaster.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
DefaultFileSystemMaster.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
void |
RpcContext.journal(Journal.JournalEntry entry)
Syntax sugar for getJournalContext().append(entry).
|
void |
DefaultFileSystemMaster.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
InodeFile.toJournalEntry() |
Journal.JournalEntry |
InodeDirectoryIdGenerator.toJournalEntry() |
Journal.JournalEntry |
InodeDirectory.toJournalEntry() |
Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
MountTable.getJournalEntryIterator() |
Iterator<Journal.JournalEntry> |
InodeTree.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
JournalFileParser.next()
Parses a journal file and returns the next entry from the journal file.
|
Journal.JournalEntry |
JournalReader.read()
Reads an entry from the journal.
|
Journal.JournalEntry |
JournalEntryStreamReader.readEntry()
Reads a journal entry from the input stream.
|
Journal.JournalEntry |
JournalEntryRepresentable.toJournalEntry() |
Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
JournalEntryIterable.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
void |
MasterJournalContext.append(Journal.JournalEntry entry) |
void |
NoopJournalContext.append(Journal.JournalEntry entry) |
void |
StateChangeJournalContext.append(Journal.JournalEntry entry) |
void |
JournalContext.append(Journal.JournalEntry entry) |
long |
AsyncJournalWriter.appendEntry(Journal.JournalEntry entry)
Appends a
Journal.JournalEntry for writing to the journal. |
static String |
JournalEntryAssociation.getMasterForEntry(Journal.JournalEntry entry) |
void |
JournalEntryStateMachine.processJournalEntry(Journal.JournalEntry entry)
Applies a journal entry to the state machine.
|
void |
JournalWriter.write(Journal.JournalEntry entry)
Writes an entry.
|
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
NoopJournalReader.read() |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
UfsJournalFileParser.next() |
Journal.JournalEntry |
UfsJournalReader.read() |
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 |
ProtoBufJournalFormatter.serialize(Journal.JournalEntry entry,
OutputStream outputStream) |
void |
JournalFormatter.serialize(Journal.JournalEntry entry,
OutputStream outputStream)
Serializes the given entry and writes it to the given output stream.
|
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 |
---|---|
Iterator<Journal.JournalEntry> |
DefaultKeyValueMaster.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultKeyValueMaster.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
DefaultLineageMaster.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultLineageMaster.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry |
LineageIdGenerator.toJournalEntry() |
Journal.JournalEntry |
Lineage.toJournalEntry() |
Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
LineageStore.getJournalEntryIterator()
Note that this method is not threadsafe.
|
Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
DefaultMetaMaster.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMetaMaster.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
DefaultMetricsMaster.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMetricsMaster.processJournalEntry(Journal.JournalEntry entry) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<Journal.JournalEntry> |
Journal.JournalEntry.PARSER |
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() |
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(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 |
---|---|
com.google.protobuf.Parser<Journal.JournalEntry> |
Journal.JournalEntry.getParserForType() |
Modifier and Type | Method and Description |
---|---|
Journal.JournalEntry.Builder |
Journal.JournalEntry.Builder.mergeFrom(Journal.JournalEntry other) |
static Journal.JournalEntry.Builder |
Journal.JournalEntry.newBuilder(Journal.JournalEntry prototype) |
Modifier and Type | Method and Description |
---|---|
Iterator<Journal.JournalEntry> |
MasterUfsManager.getJournalEntryIterator() |
Copyright © 2023. All Rights Reserved.