public static final class RpcHeaderProtos.RpcResponseHeaderProto extends com.google.protobuf.GeneratedMessage implements RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
hadoop.common.RpcResponseHeaderProto
Rpc Response Header +------------------------------------------------------------------+ | Rpc total response length in bytes (4 bytes int) | | (sum of next two parts) | +------------------------------------------------------------------+ | RpcResponseHeaderProto - serialized delimited ie has len | +------------------------------------------------------------------+ | if request is successful: | | - RpcResponse - The actual rpc response bytes follow | | the response header | | This response is serialized based on RpcKindProto | | if request fails : | | The rpc response header contains the necessary info | +------------------------------------------------------------------+ Note that rpc response header is also used when connection setup fails. Ie the response looks like a rpc response with a fake callId.
Modifier and Type | Class and Description |
---|---|
static class |
RpcHeaderProtos.RpcResponseHeaderProto.Builder
Protobuf type
hadoop.common.RpcResponseHeaderProto |
static class |
RpcHeaderProtos.RpcResponseHeaderProto.RpcErrorCodeProto
Protobuf enum
hadoop.common.RpcResponseHeaderProto.RpcErrorCodeProto |
static class |
RpcHeaderProtos.RpcResponseHeaderProto.RpcStatusProto
Protobuf enum
hadoop.common.RpcResponseHeaderProto.RpcStatusProto |
com.google.protobuf.GeneratedMessage.BuilderParent, com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessage.ExtendableBuilder>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingType extends com.google.protobuf.Message,Type>
Modifier and Type | Field and Description |
---|---|
static int |
CALLID_FIELD_NUMBER |
static int |
CLIENTID_FIELD_NUMBER |
static int |
ERRORDETAIL_FIELD_NUMBER |
static int |
ERRORMSG_FIELD_NUMBER |
static int |
EXCEPTIONCLASSNAME_FIELD_NUMBER |
static com.google.protobuf.Parser<RpcHeaderProtos.RpcResponseHeaderProto> |
PARSER |
static int |
RETRYCOUNT_FIELD_NUMBER |
static int |
SERVERIPCVERSIONNUM_FIELD_NUMBER |
static int |
STATUS_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
int |
getCallId()
required uint32 callId = 1; |
com.google.protobuf.ByteString |
getClientId()
optional bytes clientId = 7; |
static RpcHeaderProtos.RpcResponseHeaderProto |
getDefaultInstance() |
RpcHeaderProtos.RpcResponseHeaderProto |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
RpcHeaderProtos.RpcResponseHeaderProto.RpcErrorCodeProto |
getErrorDetail()
optional .hadoop.common.RpcResponseHeaderProto.RpcErrorCodeProto errorDetail = 6; |
String |
getErrorMsg()
optional string errorMsg = 5; |
com.google.protobuf.ByteString |
getErrorMsgBytes()
optional string errorMsg = 5; |
String |
getExceptionClassName()
optional string exceptionClassName = 4; |
com.google.protobuf.ByteString |
getExceptionClassNameBytes()
optional string exceptionClassName = 4; |
com.google.protobuf.Parser<RpcHeaderProtos.RpcResponseHeaderProto> |
getParserForType() |
int |
getRetryCount()
optional sint32 retryCount = 8 [default = -1]; |
int |
getSerializedSize() |
int |
getServerIpcVersionNum()
optional uint32 serverIpcVersionNum = 3; |
RpcHeaderProtos.RpcResponseHeaderProto.RpcStatusProto |
getStatus()
required .hadoop.common.RpcResponseHeaderProto.RpcStatusProto status = 2; |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
boolean |
hasCallId()
required uint32 callId = 1; |
boolean |
hasClientId()
optional bytes clientId = 7; |
boolean |
hasErrorDetail()
optional .hadoop.common.RpcResponseHeaderProto.RpcErrorCodeProto errorDetail = 6; |
boolean |
hasErrorMsg()
optional string errorMsg = 5; |
boolean |
hasExceptionClassName()
optional string exceptionClassName = 4; |
int |
hashCode() |
boolean |
hasRetryCount()
optional sint32 retryCount = 8 [default = -1]; |
boolean |
hasServerIpcVersionNum()
optional uint32 serverIpcVersionNum = 3; |
boolean |
hasStatus()
required .hadoop.common.RpcResponseHeaderProto.RpcStatusProto status = 2; |
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static RpcHeaderProtos.RpcResponseHeaderProto.Builder |
newBuilder() |
static RpcHeaderProtos.RpcResponseHeaderProto.Builder |
newBuilder(RpcHeaderProtos.RpcResponseHeaderProto prototype) |
RpcHeaderProtos.RpcResponseHeaderProto.Builder |
newBuilderForType() |
protected RpcHeaderProtos.RpcResponseHeaderProto.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseDelimitedFrom(InputStream input) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseFrom(byte[] data) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseFrom(com.google.protobuf.ByteString data) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseFrom(com.google.protobuf.CodedInputStream input) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseFrom(InputStream input) |
static RpcHeaderProtos.RpcResponseHeaderProto |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
RpcHeaderProtos.RpcResponseHeaderProto.Builder |
toBuilder() |
protected Object |
writeReplace() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
getAllFields, getDescriptorForType, getField, getRepeatedField, getRepeatedFieldCount, hasField, makeExtensionsImmutable, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtension, parseUnknownField
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
toByteArray, toByteString, writeDelimitedTo, writeTo
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public static com.google.protobuf.Parser<RpcHeaderProtos.RpcResponseHeaderProto> PARSER
public static final int CALLID_FIELD_NUMBER
public static final int STATUS_FIELD_NUMBER
public static final int SERVERIPCVERSIONNUM_FIELD_NUMBER
public static final int EXCEPTIONCLASSNAME_FIELD_NUMBER
public static final int ERRORMSG_FIELD_NUMBER
public static final int ERRORDETAIL_FIELD_NUMBER
public static final int CLIENTID_FIELD_NUMBER
public static final int RETRYCOUNT_FIELD_NUMBER
public static RpcHeaderProtos.RpcResponseHeaderProto getDefaultInstance()
public RpcHeaderProtos.RpcResponseHeaderProto getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields
in interface com.google.protobuf.MessageOrBuilder
getUnknownFields
in class com.google.protobuf.GeneratedMessage
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessage
public com.google.protobuf.Parser<RpcHeaderProtos.RpcResponseHeaderProto> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessage
public boolean hasCallId()
required uint32 callId = 1;
callId used in Request
hasCallId
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public int getCallId()
required uint32 callId = 1;
callId used in Request
getCallId
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public boolean hasStatus()
required .hadoop.common.RpcResponseHeaderProto.RpcStatusProto status = 2;
hasStatus
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public RpcHeaderProtos.RpcResponseHeaderProto.RpcStatusProto getStatus()
required .hadoop.common.RpcResponseHeaderProto.RpcStatusProto status = 2;
getStatus
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public boolean hasServerIpcVersionNum()
optional uint32 serverIpcVersionNum = 3;
Sent if success or fail
hasServerIpcVersionNum
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public int getServerIpcVersionNum()
optional uint32 serverIpcVersionNum = 3;
Sent if success or fail
getServerIpcVersionNum
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public boolean hasExceptionClassName()
optional string exceptionClassName = 4;
if request fails
hasExceptionClassName
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public String getExceptionClassName()
optional string exceptionClassName = 4;
if request fails
getExceptionClassName
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public com.google.protobuf.ByteString getExceptionClassNameBytes()
optional string exceptionClassName = 4;
if request fails
getExceptionClassNameBytes
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public boolean hasErrorMsg()
optional string errorMsg = 5;
if request fails, often contains strack trace
hasErrorMsg
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public String getErrorMsg()
optional string errorMsg = 5;
if request fails, often contains strack trace
getErrorMsg
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public com.google.protobuf.ByteString getErrorMsgBytes()
optional string errorMsg = 5;
if request fails, often contains strack trace
getErrorMsgBytes
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public boolean hasErrorDetail()
optional .hadoop.common.RpcResponseHeaderProto.RpcErrorCodeProto errorDetail = 6;
in case of error
hasErrorDetail
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public RpcHeaderProtos.RpcResponseHeaderProto.RpcErrorCodeProto getErrorDetail()
optional .hadoop.common.RpcResponseHeaderProto.RpcErrorCodeProto errorDetail = 6;
in case of error
getErrorDetail
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public boolean hasClientId()
optional bytes clientId = 7;
Globally unique client ID
hasClientId
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public com.google.protobuf.ByteString getClientId()
optional bytes clientId = 7;
Globally unique client ID
getClientId
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public boolean hasRetryCount()
optional sint32 retryCount = 8 [default = -1];
hasRetryCount
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public int getRetryCount()
optional sint32 retryCount = 8 [default = -1];
getRetryCount
in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessage
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.AbstractMessage
IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.AbstractMessage
protected Object writeReplace() throws ObjectStreamException
writeReplace
in class com.google.protobuf.GeneratedMessage
ObjectStreamException
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(InputStream input) throws IOException
IOException
public static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static RpcHeaderProtos.RpcResponseHeaderProto parseDelimitedFrom(InputStream input) throws IOException
IOException
public static RpcHeaderProtos.RpcResponseHeaderProto parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOException
public static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static RpcHeaderProtos.RpcResponseHeaderProto.Builder newBuilder()
public RpcHeaderProtos.RpcResponseHeaderProto.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static RpcHeaderProtos.RpcResponseHeaderProto.Builder newBuilder(RpcHeaderProtos.RpcResponseHeaderProto prototype)
public RpcHeaderProtos.RpcResponseHeaderProto.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
protected RpcHeaderProtos.RpcResponseHeaderProto.Builder newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent)
newBuilderForType
in class com.google.protobuf.GeneratedMessage
Copyright © 2017 Apache Software Foundation. All Rights Reserved.