@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) @InterfaceStability.Evolving public class RpcServer.Call extends Object implements RpcCallContext
Modifier and Type | Field and Description |
---|---|
protected CellScanner |
cellScanner |
protected RpcServer.Connection |
connection |
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader |
header |
protected int |
id |
protected boolean |
isError |
protected com.google.protobuf.Descriptors.MethodDescriptor |
md |
protected com.google.protobuf.Message |
param |
protected RpcServer.Responder |
responder |
protected org.apache.hadoop.hbase.ipc.BufferChain |
response
Chain of buffers to send as response.
|
protected com.google.protobuf.BlockingService |
service |
protected long |
size |
protected long |
timestamp |
protected org.apache.htrace.TraceInfo |
tinfo |
Modifier and Type | Method and Description |
---|---|
long |
disconnectSince()
Check if the caller who made this IPC call has disconnected.
|
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.VersionInfo |
getClientVersionInfo() |
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader |
getHeader() |
int |
getPriority() |
InetAddress |
getRemoteAddress() |
org.apache.hadoop.security.UserGroupInformation |
getRemoteUser() |
User |
getRequestUser()
Returns the user credentials associated with the current RPC request or
null if no credentials were provided. |
String |
getRequestUserName() |
long |
getResponseBlockSize() |
long |
getResponseCellSize()
The size of response cells that have been accumulated so far.
|
long |
getSize() |
boolean |
hasPriority() |
void |
incrementResponseBlockSize(long blockSize) |
void |
incrementResponseCellSize(long cellSize)
Add on the given amount to the retained cell size.
|
boolean |
isClientCellBlockSupported()
If the client connected and specified a codec to use, then we will use this codec making
cellblocks to return.
|
boolean |
isRetryImmediatelySupported() |
void |
sendResponseIfReady() |
protected void |
setResponse(Object m,
CellScanner cells,
Throwable t,
String errorMsg) |
protected void |
setSaslTokenResponse(ByteBuffer response) |
String |
toString() |
protected int id
protected com.google.protobuf.BlockingService service
protected com.google.protobuf.Descriptors.MethodDescriptor md
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader header
protected com.google.protobuf.Message param
protected CellScanner cellScanner
protected RpcServer.Connection connection
protected long timestamp
protected org.apache.hadoop.hbase.ipc.BufferChain response
protected RpcServer.Responder responder
protected long size
protected boolean isError
protected org.apache.htrace.TraceInfo tinfo
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader getHeader()
public boolean hasPriority()
public int getPriority()
protected void setSaslTokenResponse(ByteBuffer response)
protected void setResponse(Object m, CellScanner cells, Throwable t, String errorMsg)
public boolean isClientCellBlockSupported()
RpcCallContext
isClientCellBlockSupported
in interface RpcCallContext
public long disconnectSince()
RpcCallContext
disconnectSince
in interface RpcCallContext
public long getSize()
public long getResponseCellSize()
RpcCallContext
getResponseCellSize
in interface RpcCallContext
public void incrementResponseCellSize(long cellSize)
RpcCallContext
incrementResponseCellSize
in interface RpcCallContext
public long getResponseBlockSize()
getResponseBlockSize
in interface RpcCallContext
public void incrementResponseBlockSize(long blockSize)
incrementResponseBlockSize
in interface RpcCallContext
public void sendResponseIfReady() throws IOException
IOException
public org.apache.hadoop.security.UserGroupInformation getRemoteUser()
public User getRequestUser()
RpcCallContext
null
if no credentials were provided.getRequestUser
in interface RpcCallContext
public String getRequestUserName()
getRequestUserName
in interface RpcCallContext
public InetAddress getRemoteAddress()
getRemoteAddress
in interface RpcCallContext
public org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.VersionInfo getClientVersionInfo()
getClientVersionInfo
in interface RpcCallContext
public boolean isRetryImmediatelySupported()
isRetryImmediatelySupported
in interface RpcCallContext
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.