org.apache.hadoop.hdfs.qjournal.protocol

Interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Enclosing class:

QJournalProtocolProtos.QJournalProtocolService

public static interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Method Summary

Methods

Modifier and Type	Method and Description
QJournalProtocolProtos.AcceptRecoveryResponseProto	acceptRecovery(com.google.protobuf.RpcController controller, QJournalProtocolProtos.AcceptRecoveryRequestProto request)
QJournalProtocolProtos.CanRollBackResponseProto	canRollBack(com.google.protobuf.RpcController controller, QJournalProtocolProtos.CanRollBackRequestProto request)
QJournalProtocolProtos.DiscardSegmentsResponseProto	discardSegments(com.google.protobuf.RpcController controller, QJournalProtocolProtos.DiscardSegmentsRequestProto request)
QJournalProtocolProtos.DoFinalizeResponseProto	doFinalize(com.google.protobuf.RpcController controller, QJournalProtocolProtos.DoFinalizeRequestProto request)
QJournalProtocolProtos.DoPreUpgradeResponseProto	doPreUpgrade(com.google.protobuf.RpcController controller, QJournalProtocolProtos.DoPreUpgradeRequestProto request)
QJournalProtocolProtos.DoRollbackResponseProto	doRollback(com.google.protobuf.RpcController controller, QJournalProtocolProtos.DoRollbackRequestProto request)
QJournalProtocolProtos.DoUpgradeResponseProto	doUpgrade(com.google.protobuf.RpcController controller, QJournalProtocolProtos.DoUpgradeRequestProto request)
QJournalProtocolProtos.FinalizeLogSegmentResponseProto	finalizeLogSegment(com.google.protobuf.RpcController controller, QJournalProtocolProtos.FinalizeLogSegmentRequestProto request)
QJournalProtocolProtos.FormatResponseProto	format(com.google.protobuf.RpcController controller, QJournalProtocolProtos.FormatRequestProto request)
QJournalProtocolProtos.GetEditLogManifestResponseProto	getEditLogManifest(com.google.protobuf.RpcController controller, QJournalProtocolProtos.GetEditLogManifestRequestProto request)
QJournalProtocolProtos.GetJournalCTimeResponseProto	getJournalCTime(com.google.protobuf.RpcController controller, QJournalProtocolProtos.GetJournalCTimeRequestProto request)
QJournalProtocolProtos.GetJournalStateResponseProto	getJournalState(com.google.protobuf.RpcController controller, QJournalProtocolProtos.GetJournalStateRequestProto request)
QJournalProtocolProtos.HeartbeatResponseProto	heartbeat(com.google.protobuf.RpcController controller, QJournalProtocolProtos.HeartbeatRequestProto request)
QJournalProtocolProtos.IsFormattedResponseProto	isFormatted(com.google.protobuf.RpcController controller, QJournalProtocolProtos.IsFormattedRequestProto request)
QJournalProtocolProtos.JournalResponseProto	journal(com.google.protobuf.RpcController controller, QJournalProtocolProtos.JournalRequestProto request)
QJournalProtocolProtos.NewEpochResponseProto	newEpoch(com.google.protobuf.RpcController controller, QJournalProtocolProtos.NewEpochRequestProto request)
QJournalProtocolProtos.PrepareRecoveryResponseProto	prepareRecovery(com.google.protobuf.RpcController controller, QJournalProtocolProtos.PrepareRecoveryRequestProto request)
QJournalProtocolProtos.PurgeLogsResponseProto	purgeLogs(com.google.protobuf.RpcController controller, QJournalProtocolProtos.PurgeLogsRequestProto request)
QJournalProtocolProtos.StartLogSegmentResponseProto	startLogSegment(com.google.protobuf.RpcController controller, QJournalProtocolProtos.StartLogSegmentRequestProto request)

Method Detail

isFormatted

QJournalProtocolProtos.IsFormattedResponseProto isFormatted(com.google.protobuf.RpcController controller,
                                                          QJournalProtocolProtos.IsFormattedRequestProto request)
                                                            throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

discardSegments

QJournalProtocolProtos.DiscardSegmentsResponseProto discardSegments(com.google.protobuf.RpcController controller,
                                                                  QJournalProtocolProtos.DiscardSegmentsRequestProto request)
                                                                    throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

getJournalCTime

QJournalProtocolProtos.GetJournalCTimeResponseProto getJournalCTime(com.google.protobuf.RpcController controller,
                                                                  QJournalProtocolProtos.GetJournalCTimeRequestProto request)
                                                                    throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

doPreUpgrade

QJournalProtocolProtos.DoPreUpgradeResponseProto doPreUpgrade(com.google.protobuf.RpcController controller,
                                                            QJournalProtocolProtos.DoPreUpgradeRequestProto request)
                                                              throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

doUpgrade

QJournalProtocolProtos.DoUpgradeResponseProto doUpgrade(com.google.protobuf.RpcController controller,
                                                      QJournalProtocolProtos.DoUpgradeRequestProto request)
                                                        throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

doFinalize

QJournalProtocolProtos.DoFinalizeResponseProto doFinalize(com.google.protobuf.RpcController controller,
                                                        QJournalProtocolProtos.DoFinalizeRequestProto request)
                                                          throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

canRollBack

QJournalProtocolProtos.CanRollBackResponseProto canRollBack(com.google.protobuf.RpcController controller,
                                                          QJournalProtocolProtos.CanRollBackRequestProto request)
                                                            throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

doRollback

QJournalProtocolProtos.DoRollbackResponseProto doRollback(com.google.protobuf.RpcController controller,
                                                        QJournalProtocolProtos.DoRollbackRequestProto request)
                                                          throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

getJournalState

QJournalProtocolProtos.GetJournalStateResponseProto getJournalState(com.google.protobuf.RpcController controller,
                                                                  QJournalProtocolProtos.GetJournalStateRequestProto request)
                                                                    throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

newEpoch

QJournalProtocolProtos.NewEpochResponseProto newEpoch(com.google.protobuf.RpcController controller,
                                                    QJournalProtocolProtos.NewEpochRequestProto request)
                                                      throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

format

QJournalProtocolProtos.FormatResponseProto format(com.google.protobuf.RpcController controller,
                                                QJournalProtocolProtos.FormatRequestProto request)
                                                  throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

journal

QJournalProtocolProtos.JournalResponseProto journal(com.google.protobuf.RpcController controller,
                                                  QJournalProtocolProtos.JournalRequestProto request)
                                                    throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

heartbeat

QJournalProtocolProtos.HeartbeatResponseProto heartbeat(com.google.protobuf.RpcController controller,
                                                      QJournalProtocolProtos.HeartbeatRequestProto request)
                                                        throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

startLogSegment

QJournalProtocolProtos.StartLogSegmentResponseProto startLogSegment(com.google.protobuf.RpcController controller,
                                                                  QJournalProtocolProtos.StartLogSegmentRequestProto request)
                                                                    throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

finalizeLogSegment

QJournalProtocolProtos.FinalizeLogSegmentResponseProto finalizeLogSegment(com.google.protobuf.RpcController controller,
                                                                        QJournalProtocolProtos.FinalizeLogSegmentRequestProto request)
                                                                          throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

purgeLogs

QJournalProtocolProtos.PurgeLogsResponseProto purgeLogs(com.google.protobuf.RpcController controller,
                                                      QJournalProtocolProtos.PurgeLogsRequestProto request)
                                                        throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

getEditLogManifest

QJournalProtocolProtos.GetEditLogManifestResponseProto getEditLogManifest(com.google.protobuf.RpcController controller,
                                                                        QJournalProtocolProtos.GetEditLogManifestRequestProto request)
                                                                          throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

prepareRecovery

QJournalProtocolProtos.PrepareRecoveryResponseProto prepareRecovery(com.google.protobuf.RpcController controller,
                                                                  QJournalProtocolProtos.PrepareRecoveryRequestProto request)
                                                                    throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

acceptRecovery

QJournalProtocolProtos.AcceptRecoveryResponseProto acceptRecovery(com.google.protobuf.RpcController controller,
                                                                QJournalProtocolProtos.AcceptRecoveryRequestProto request)
                                                                  throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException