Package | Description |
---|---|
org.apache.hadoop.contrib.bkjournal | |
org.apache.hadoop.hdfs.qjournal.client | |
org.apache.hadoop.hdfs.server.namenode |
Modifier and Type | Method and Description |
---|---|
void |
BookKeeperJournalManager.selectInputStreams(Collection<EditLogInputStream> streams,
long fromTxId,
boolean inProgressOk) |
void |
BookKeeperJournalManager.selectInputStreams(Collection<EditLogInputStream> streams,
long fromTxId,
boolean inProgressOk,
boolean forReading) |
Modifier and Type | Method and Description |
---|---|
void |
QuorumJournalManager.selectInputStreams(Collection<EditLogInputStream> streams,
long fromTxnId,
boolean inProgressOk) |
void |
QuorumJournalManager.selectInputStreams(Collection<EditLogInputStream> streams,
long fromTxnId,
boolean inProgressOk,
boolean forReading) |
Modifier and Type | Class and Description |
---|---|
class |
EditLogFileInputStream
An implementation of the abstract class
EditLogInputStream , which
reads edits from a file. |
Modifier and Type | Field and Description |
---|---|
static Comparator<EditLogInputStream> |
JournalSet.EDIT_LOG_INPUT_STREAM_COMPARATOR |
Modifier and Type | Method and Description |
---|---|
static EditLogInputStream |
EditLogFileInputStream.fromUrl(URL url,
long startTxId,
long endTxId,
boolean inProgress)
Open an EditLogInputStream for the given URL.
|
Modifier and Type | Method and Description |
---|---|
Collection<EditLogInputStream> |
FSEditLog.selectInputStreams(long fromTxId,
long toAtLeastTxId) |
Collection<EditLogInputStream> |
FSEditLog.selectInputStreams(long fromTxId,
long toAtLeastTxId,
MetaRecoveryContext recovery,
boolean inProgressOk)
Select a list of input streams to load
|
Collection<EditLogInputStream> |
FSEditLog.selectInputStreams(long fromTxId,
long toAtLeastTxId,
MetaRecoveryContext recovery,
boolean inProgressOk,
boolean forReading)
Select a list of input streams.
|
Modifier and Type | Method and Description |
---|---|
static void |
JournalSet.chainAndMakeRedundantStreams(Collection<EditLogInputStream> outStreams,
PriorityQueue<EditLogInputStream> allStreams,
long fromTxId) |
static void |
JournalSet.chainAndMakeRedundantStreams(Collection<EditLogInputStream> outStreams,
PriorityQueue<EditLogInputStream> allStreams,
long fromTxId) |
long |
FSImage.loadEdits(Iterable<EditLogInputStream> editStreams,
FSNamesystem target,
MetaRecoveryContext recovery)
Load the specified list of edit files into the image.
|
void |
JournalSet.selectInputStreams(Collection<EditLogInputStream> streams,
long fromTxId,
boolean inProgressOk,
boolean forReading)
In this function, we get a bunch of streams from all of our JournalManager
objects.
|
void |
FileJournalManager.selectInputStreams(Collection<EditLogInputStream> streams,
long fromTxId,
boolean inProgressOk,
boolean forReading) |
void |
FSEditLog.selectInputStreams(Collection<EditLogInputStream> streams,
long fromTxId,
boolean inProgressOk,
boolean forReading) |
Copyright © 2013 Apache Software Foundation. All rights reserved.