|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use RPCProtos.RpcRequestBody | |
|---|---|
| org.apache.hadoop.hbase.ipc | Tools to help define network clients and servers. |
| org.apache.hadoop.hbase.monitoring | |
| org.apache.hadoop.hbase.protobuf.generated | |
| Uses of RPCProtos.RpcRequestBody in org.apache.hadoop.hbase.ipc |
|---|
| Fields in org.apache.hadoop.hbase.ipc declared as RPCProtos.RpcRequestBody | |
|---|---|
protected RPCProtos.RpcRequestBody |
HBaseServer.Call.rpcRequestBody
|
| Methods in org.apache.hadoop.hbase.ipc with parameters of type RPCProtos.RpcRequestBody | |
|---|---|
com.google.protobuf.Message |
RpcServer.call(Class<? extends IpcProtocol> protocol,
RPCProtos.RpcRequestBody param,
long receiveTime,
MonitoredRPCHandler status)
Called for each call. |
com.google.protobuf.Message[] |
HBaseClient.call(RPCProtos.RpcRequestBody[] params,
InetSocketAddress[] addresses,
Class<? extends IpcProtocol> protocol,
User ticket)
Makes a set of calls in parallel. |
com.google.protobuf.Message |
HBaseClient.call(RPCProtos.RpcRequestBody param,
InetSocketAddress address)
Make a call, passing param, to the IPC server running at
address, returning the value. |
com.google.protobuf.Message |
HBaseClient.call(RPCProtos.RpcRequestBody param,
InetSocketAddress addr,
Class<? extends IpcProtocol> protocol,
User ticket,
int rpcTimeout)
Make a call, passing param, to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, returning the value. |
com.google.protobuf.Message |
HBaseClient.call(RPCProtos.RpcRequestBody param,
InetSocketAddress addr,
User ticket,
int rpcTimeout)
|
protected int |
HBaseServer.getQosLevel(RPCProtos.RpcRequestBody rpcRequestBody)
|
| Method parameters in org.apache.hadoop.hbase.ipc with type arguments of type RPCProtos.RpcRequestBody | |
|---|---|
void |
RpcServer.setQosFunction(com.google.common.base.Function<RPCProtos.RpcRequestBody,Integer> newFunc)
|
void |
HBaseServer.setQosFunction(com.google.common.base.Function<RPCProtos.RpcRequestBody,Integer> newFunc)
Gets the QOS level for this call. |
| Constructors in org.apache.hadoop.hbase.ipc with parameters of type RPCProtos.RpcRequestBody | |
|---|---|
HBaseClient.Call(RPCProtos.RpcRequestBody param)
|
|
HBaseClient.ParallelCall(RPCProtos.RpcRequestBody param,
HBaseClient.ParallelResults results,
int index)
|
|
HBaseServer.Call(int id,
RPCProtos.RpcRequestBody rpcRequestBody,
HBaseServer.Connection connection,
HBaseServer.Responder responder,
long size,
org.cloudera.htrace.TraceInfo tinfo)
|
|
| Uses of RPCProtos.RpcRequestBody in org.apache.hadoop.hbase.monitoring |
|---|
| Methods in org.apache.hadoop.hbase.monitoring with parameters of type RPCProtos.RpcRequestBody | |
|---|---|
void |
MonitoredRPCHandlerImpl.setRPCPacket(RPCProtos.RpcRequestBody param)
Gives this instance a reference to the protobuf received by the RPC, so that it can later compute its size if asked for it. |
void |
MonitoredRPCHandler.setRPCPacket(RPCProtos.RpcRequestBody param)
|
| Uses of RPCProtos.RpcRequestBody in org.apache.hadoop.hbase.protobuf.generated |
|---|
| Methods in org.apache.hadoop.hbase.protobuf.generated that return RPCProtos.RpcRequestBody | |
|---|---|
RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.Builder.build()
|
RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.Builder.buildPartial()
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.getDefaultInstance()
|
RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.getDefaultInstanceForType()
|
RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.Builder.getDefaultInstanceForType()
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseDelimitedFrom(InputStream input)
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseFrom(byte[] data)
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseFrom(com.google.protobuf.ByteString data)
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseFrom(com.google.protobuf.CodedInputStream input)
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseFrom(InputStream input)
|
static RPCProtos.RpcRequestBody |
RPCProtos.RpcRequestBody.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
| Methods in org.apache.hadoop.hbase.protobuf.generated with parameters of type RPCProtos.RpcRequestBody | |
|---|---|
RPCProtos.RpcRequestBody.Builder |
RPCProtos.RpcRequestBody.Builder.mergeFrom(RPCProtos.RpcRequestBody other)
|
static RPCProtos.RpcRequestBody.Builder |
RPCProtos.RpcRequestBody.newBuilder(RPCProtos.RpcRequestBody prototype)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||