@InterfaceAudience.Private public interface JournalProtocol
Modifier and Type | Field and Description |
---|---|
static long |
versionID
This class is used by both the Namenode (client) and BackupNode (server)
to insulate from the protocol serialization.
|
Modifier and Type | Method and Description |
---|---|
FenceResponse |
fence(JournalInfo journalInfo,
long epoch,
String fencerInfo)
Request to fence any other journal writers.
|
void |
journal(JournalInfo journalInfo,
long epoch,
long firstTxnId,
int numTxns,
byte[] records)
Journal edit records.
|
void |
startLogSegment(JournalInfo journalInfo,
long epoch,
long txid)
Notify the BackupNode that the NameNode has rolled its edit logs
and is now writing a new log segment.
|
static final long versionID
void journal(JournalInfo journalInfo, long epoch, long firstTxnId, int numTxns, byte[] records) throws IOException
EditLogBackupOutputStream
in order to synchronize meta-data
changes with the backup namespace image.journalInfo
- journal informationepoch
- marks beginning a new journal writerfirstTxnId
- the first transaction of this batchnumTxns
- number of transactionsrecords
- byte array containing serialized journal recordsFencedException
- if the resource has been fencedIOException
void startLogSegment(JournalInfo journalInfo, long epoch, long txid) throws IOException
journalInfo
- journal informationepoch
- marks beginning a new journal writertxid
- the first txid in the new logFencedException
- if the resource has been fencedIOException
FenceResponse fence(JournalInfo journalInfo, long epoch, String fencerInfo) throws IOException
journalInfo
- journal informationepoch
- marks beginning a new journal writerfencerInfo
- info about fencer for debugging purposesFencedException
- if the resource has been fencedIOException
Copyright © 2013 Apache Software Foundation. All rights reserved.