Package | Description |
---|---|
org.apache.hadoop.hdfs.qjournal.protocol | |
org.apache.hadoop.hdfs.qjournal.protocolPB |
Modifier and Type | Method and Description |
---|---|
void |
QJournalProtocol.acceptRecovery(RequestInfo reqInfo,
QJournalProtocolProtos.SegmentStateProto stateToAccept,
URL fromUrl)
Accept a proposed recovery for the given transaction ID.
|
void |
QJournalProtocol.finalizeLogSegment(RequestInfo reqInfo,
long startTxId,
long endTxId)
Finalize the given log segment on the JournalNode.
|
void |
QJournalProtocol.heartbeat(RequestInfo reqInfo)
Heartbeat.
|
void |
QJournalProtocol.journal(RequestInfo reqInfo,
long segmentTxId,
long firstTxnId,
int numTxns,
byte[] records)
Journal edit records.
|
QJournalProtocolProtos.PrepareRecoveryResponseProto |
QJournalProtocol.prepareRecovery(RequestInfo reqInfo,
long segmentTxId)
Begin the recovery process for a given segment.
|
void |
QJournalProtocol.purgeLogsOlderThan(RequestInfo requestInfo,
long minTxIdToKeep) |
void |
QJournalProtocol.startLogSegment(RequestInfo reqInfo,
long txid)
Start writing to a new log segment on the JournalNode.
|
Modifier and Type | Method and Description |
---|---|
void |
QJournalProtocolTranslatorPB.acceptRecovery(RequestInfo reqInfo,
QJournalProtocolProtos.SegmentStateProto stateToAccept,
URL fromUrl) |
void |
QJournalProtocolTranslatorPB.finalizeLogSegment(RequestInfo reqInfo,
long startTxId,
long endTxId) |
void |
QJournalProtocolTranslatorPB.heartbeat(RequestInfo reqInfo) |
void |
QJournalProtocolTranslatorPB.journal(RequestInfo reqInfo,
long segmentTxId,
long firstTxnId,
int numTxns,
byte[] records) |
QJournalProtocolProtos.PrepareRecoveryResponseProto |
QJournalProtocolTranslatorPB.prepareRecovery(RequestInfo reqInfo,
long segmentTxId) |
void |
QJournalProtocolTranslatorPB.purgeLogsOlderThan(RequestInfo reqInfo,
long minTxIdToKeep) |
void |
QJournalProtocolTranslatorPB.startLogSegment(RequestInfo reqInfo,
long txid) |
Copyright © 2013 Apache Software Foundation. All rights reserved.