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 |
STATEID_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; |
long |
getStateId()
optional int64 stateId = 9; |
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 |
hasStateId()
optional int64 stateId = 9; |
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, parseUnknownFieldfindInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toStringtoByteArray, toByteString, writeDelimitedTo, writeToclone, finalize, getClass, notify, notifyAll, wait, wait, waitpublic 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 final int STATEID_FIELD_NUMBER
public static RpcHeaderProtos.RpcResponseHeaderProto getDefaultInstance()
public RpcHeaderProtos.RpcResponseHeaderProto getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderpublic final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields in interface com.google.protobuf.MessageOrBuildergetUnknownFields in class com.google.protobuf.GeneratedMessagepublic static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessagepublic com.google.protobuf.Parser<RpcHeaderProtos.RpcResponseHeaderProto> getParserForType()
getParserForType in interface com.google.protobuf.MessagegetParserForType in interface com.google.protobuf.MessageLitegetParserForType in class com.google.protobuf.GeneratedMessagepublic boolean hasCallId()
required uint32 callId = 1;
callId used in Request
hasCallId in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic int getCallId()
required uint32 callId = 1;
callId used in Request
getCallId in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic boolean hasStatus()
required .hadoop.common.RpcResponseHeaderProto.RpcStatusProto status = 2;hasStatus in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic RpcHeaderProtos.RpcResponseHeaderProto.RpcStatusProto getStatus()
required .hadoop.common.RpcResponseHeaderProto.RpcStatusProto status = 2;getStatus in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic boolean hasServerIpcVersionNum()
optional uint32 serverIpcVersionNum = 3;
Sent if success or fail
hasServerIpcVersionNum in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic int getServerIpcVersionNum()
optional uint32 serverIpcVersionNum = 3;
Sent if success or fail
getServerIpcVersionNum in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic boolean hasExceptionClassName()
optional string exceptionClassName = 4;
if request fails
hasExceptionClassName in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic String getExceptionClassName()
optional string exceptionClassName = 4;
if request fails
getExceptionClassName in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic com.google.protobuf.ByteString getExceptionClassNameBytes()
optional string exceptionClassName = 4;
if request fails
getExceptionClassNameBytes in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic boolean hasErrorMsg()
optional string errorMsg = 5;
if request fails, often contains strack trace
hasErrorMsg in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic String getErrorMsg()
optional string errorMsg = 5;
if request fails, often contains strack trace
getErrorMsg in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic com.google.protobuf.ByteString getErrorMsgBytes()
optional string errorMsg = 5;
if request fails, often contains strack trace
getErrorMsgBytes in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic boolean hasErrorDetail()
optional .hadoop.common.RpcResponseHeaderProto.RpcErrorCodeProto errorDetail = 6;
in case of error
hasErrorDetail in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic RpcHeaderProtos.RpcResponseHeaderProto.RpcErrorCodeProto getErrorDetail()
optional .hadoop.common.RpcResponseHeaderProto.RpcErrorCodeProto errorDetail = 6;
in case of error
getErrorDetail in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic boolean hasClientId()
optional bytes clientId = 7;
Globally unique client ID
hasClientId in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic com.google.protobuf.ByteString getClientId()
optional bytes clientId = 7;
Globally unique client ID
getClientId in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic boolean hasRetryCount()
optional sint32 retryCount = 8 [default = -1];hasRetryCount in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic int getRetryCount()
optional sint32 retryCount = 8 [default = -1];getRetryCount in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic boolean hasStateId()
optional int64 stateId = 9;
The last written Global State ID
hasStateId in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic long getStateId()
optional int64 stateId = 9;
The last written Global State ID
getStateId in interface RpcHeaderProtos.RpcResponseHeaderProtoOrBuilderpublic final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessagepublic void writeTo(com.google.protobuf.CodedOutputStream output)
throws IOException
writeTo in interface com.google.protobuf.MessageLitewriteTo in class com.google.protobuf.AbstractMessageIOExceptionpublic int getSerializedSize()
getSerializedSize in interface com.google.protobuf.MessageLitegetSerializedSize in class com.google.protobuf.AbstractMessageprotected Object writeReplace() throws ObjectStreamException
writeReplace in class com.google.protobuf.GeneratedMessageObjectStreamExceptionpublic boolean equals(Object obj)
equals in interface com.google.protobuf.Messageequals in class com.google.protobuf.AbstractMessagepublic int hashCode()
hashCode in interface com.google.protobuf.MessagehashCode in class com.google.protobuf.AbstractMessagepublic static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(InputStream input) throws IOException
IOExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto parseDelimitedFrom(InputStream input) throws IOException
IOExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static RpcHeaderProtos.RpcResponseHeaderProto.Builder newBuilder()
public RpcHeaderProtos.RpcResponseHeaderProto.Builder newBuilderForType()
newBuilderForType in interface com.google.protobuf.MessagenewBuilderForType in interface com.google.protobuf.MessageLitepublic static RpcHeaderProtos.RpcResponseHeaderProto.Builder newBuilder(RpcHeaderProtos.RpcResponseHeaderProto prototype)
public RpcHeaderProtos.RpcResponseHeaderProto.Builder toBuilder()
toBuilder in interface com.google.protobuf.MessagetoBuilder in interface com.google.protobuf.MessageLiteprotected RpcHeaderProtos.RpcResponseHeaderProto.Builder newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent)
newBuilderForType in class com.google.protobuf.GeneratedMessageCopyright © 2019 Apache Software Foundation. All Rights Reserved.