Uses of Class
org.apache.hadoop.hdfs.server.namenode.EditLogInputStream

Packages that use EditLogInputStream

Package	Description
org.apache.hadoop.hdfs.qjournal.client
org.apache.hadoop.hdfs.server.namenode

Uses of EditLogInputStream in org.apache.hadoop.hdfs.qjournal.client

Method parameters in org.apache.hadoop.hdfs.qjournal.client with type arguments of type EditLogInputStream

Modifier and Type	Method	Description
void	QuorumJournalManager.selectInputStreams(Collection<EditLogInputStream> streams, long fromTxnId, boolean inProgressOk)
void	QuorumJournalManager.selectInputStreams(Collection<EditLogInputStream> streams, long fromTxnId, boolean inProgressOk, boolean onlyDurableTxns)

Uses of EditLogInputStream in org.apache.hadoop.hdfs.server.namenode

Subclasses of EditLogInputStream in org.apache.hadoop.hdfs.server.namenode

Modifier and Type	Class	Description
class	EditLogFileInputStream	An implementation of the abstract class EditLogInputStream, which reads edits from a file.

Fields in org.apache.hadoop.hdfs.server.namenode with type parameters of type EditLogInputStream

Modifier and Type	Field	Description
static final Comparator<EditLogInputStream>	JournalSet.EDIT_LOG_INPUT_STREAM_COMPARATOR

Methods in org.apache.hadoop.hdfs.server.namenode that return EditLogInputStream

Modifier and Type	Method	Description
static EditLogInputStream	EditLogFileInputStream.fromByteString(org.apache.hadoop.thirdparty.protobuf.ByteString bytes, long startTxId, long endTxId, boolean inProgress)	Create an EditLogInputStream from a ByteString, i.e. an in-memory collection of bytes.
static EditLogInputStream	EditLogFileInputStream.fromUrl(org.apache.hadoop.hdfs.web.URLConnectionFactory connectionFactory, URL url, long startTxId, long endTxId, boolean inProgress)	Open an EditLogInputStream for the given URL.

Methods in org.apache.hadoop.hdfs.server.namenode that return types with arguments of type EditLogInputStream

Modifier and Type	Method	Description
Collection<EditLogInputStream>	FSEditLog.selectInputStreams(long fromTxId, long toAtLeastTxId)
Collection<EditLogInputStream>	FSEditLog.selectInputStreams(long fromTxId, long toAtLeastTxId, MetaRecoveryContext recovery, boolean inProgressOK)
Collection<EditLogInputStream>	FSEditLog.selectInputStreams(long fromTxId, long toAtLeastTxId, MetaRecoveryContext recovery, boolean inProgressOk, boolean onlyDurableTxns)	Select a list of input streams.

Method parameters in org.apache.hadoop.hdfs.server.namenode with type arguments of type EditLogInputStream

Modifier and Type	Method	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)	Load the specified list of edit files into the image.
long	FSImage.loadEdits(Iterable<EditLogInputStream> editStreams, FSNamesystem target, long maxTxnsToRead, HdfsServerConstants.StartupOption startOpt, MetaRecoveryContext recovery)
void	FileJournalManager.selectInputStreams(Collection<EditLogInputStream> streams, long fromTxnId, boolean inProgressOk)
void	FileJournalManager.selectInputStreams(Collection<EditLogInputStream> streams, long fromTxId, boolean inProgressOk, boolean onlyDurableTxns)
void	FSEditLog.selectInputStreams(Collection<EditLogInputStream> streams, long fromTxId, boolean inProgressOk, boolean onlyDurableTxns)
void	JournalSet.selectInputStreams(Collection<EditLogInputStream> streams, long fromTxId, boolean inProgressOk, boolean onlyDurableTxns)	In this function, we get a bunch of streams from all of our JournalManager objects.