Package | Description |
---|---|
org.apache.hadoop.hdfs.qjournal.client | |
org.apache.hadoop.hdfs.qjournal.protocol | |
org.apache.hadoop.hdfs.qjournal.protocolPB |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<QJournalProtocolProtos.NewEpochResponseProto> |
IPCLoggerChannel.newEpoch(long epoch) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<QJournalProtocolProtos.NewEpochResponseProto> |
QJournalProtocolProtos.NewEpochResponseProto.PARSER |
Modifier and Type | Method and Description |
---|---|
QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.Builder.build() |
QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.Builder.buildPartial() |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.getDefaultInstance() |
QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.getDefaultInstanceForType() |
QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.Builder.getDefaultInstanceForType() |
QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.QJournalProtocolService.BlockingInterface.newEpoch(com.google.protobuf.RpcController controller,
QJournalProtocolProtos.NewEpochRequestProto request) |
QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocol.newEpoch(String journalId,
NamespaceInfo nsInfo,
long epoch)
Begin a new epoch.
|
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseDelimitedFrom(InputStream input) |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseFrom(byte[] data) |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseFrom(com.google.protobuf.ByteString data) |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseFrom(com.google.protobuf.CodedInputStream input) |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseFrom(InputStream input) |
static QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolProtos.NewEpochResponseProto.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<QJournalProtocolProtos.NewEpochResponseProto> |
QJournalProtocolProtos.NewEpochResponseProto.getParserForType() |
Modifier and Type | Method and Description |
---|---|
QJournalProtocolProtos.NewEpochResponseProto.Builder |
QJournalProtocolProtos.NewEpochResponseProto.Builder.mergeFrom(QJournalProtocolProtos.NewEpochResponseProto other) |
static QJournalProtocolProtos.NewEpochResponseProto.Builder |
QJournalProtocolProtos.NewEpochResponseProto.newBuilder(QJournalProtocolProtos.NewEpochResponseProto prototype) |
Modifier and Type | Method and Description |
---|---|
abstract void |
QJournalProtocolProtos.QJournalProtocolService.newEpoch(com.google.protobuf.RpcController controller,
QJournalProtocolProtos.NewEpochRequestProto request,
com.google.protobuf.RpcCallback<QJournalProtocolProtos.NewEpochResponseProto> done)
rpc newEpoch(.hadoop.hdfs.NewEpochRequestProto) returns (.hadoop.hdfs.NewEpochResponseProto); |
void |
QJournalProtocolProtos.QJournalProtocolService.Interface.newEpoch(com.google.protobuf.RpcController controller,
QJournalProtocolProtos.NewEpochRequestProto request,
com.google.protobuf.RpcCallback<QJournalProtocolProtos.NewEpochResponseProto> done)
rpc newEpoch(.hadoop.hdfs.NewEpochRequestProto) returns (.hadoop.hdfs.NewEpochResponseProto); |
void |
QJournalProtocolProtos.QJournalProtocolService.Stub.newEpoch(com.google.protobuf.RpcController controller,
QJournalProtocolProtos.NewEpochRequestProto request,
com.google.protobuf.RpcCallback<QJournalProtocolProtos.NewEpochResponseProto> done) |
Modifier and Type | Method and Description |
---|---|
QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolServerSideTranslatorPB.newEpoch(com.google.protobuf.RpcController controller,
QJournalProtocolProtos.NewEpochRequestProto request) |
QJournalProtocolProtos.NewEpochResponseProto |
QJournalProtocolTranslatorPB.newEpoch(String jid,
NamespaceInfo nsInfo,
long epoch) |
Copyright © 2013 Apache Software Foundation. All rights reserved.