@InterfaceAudience.Private public interface RpcCallContext
Modifier and Type | Method and Description |
---|---|
long |
disconnectSince()
Check if the caller who made this IPC call has disconnected.
|
long |
getBlockBytesScanned()
Get the number of block bytes scanned by the current call.
|
Optional<X509Certificate[]> |
getClientCertificateChain()
Returns the TLS certificate(s) that the client presented to this HBase server when making its
connection.
|
org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.VersionInfo |
getClientVersionInfo()
Returns the client version info, or null if the information is not present
|
InetAddress |
getRemoteAddress()
Returns Address of remote client in this call
|
Optional<User> |
getRequestUser()
Returns the user credentials associated with the current RPC request or not present if no
credentials were provided.
|
default Optional<String> |
getRequestUserName()
Returns Current request's user name or not present if none ongoing.
|
long |
getResponseCellSize()
The size of response cells that have been accumulated so far.
|
long |
getResponseExceptionSize() |
void |
incrementBlockBytesScanned(long blockSize)
Increment the number of block bytes scanned by the current call.
|
void |
incrementResponseCellSize(long cellSize)
Add on the given amount to the retained cell size.
|
void |
incrementResponseExceptionSize(long exceptionSize) |
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 |
setCallBack(RpcCallback callback)
Sets a callback which has to be executed at the end of this RPC call.
|
long disconnectSince()
boolean isClientCellBlockSupported()
Optional<User> getRequestUser()
default Optional<String> getRequestUserName()
Optional<X509Certificate[]> getClientCertificateChain()
getRequestUser()
. Both, one, or neither may be present.InetAddress getRemoteAddress()
org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.VersionInfo getClientVersionInfo()
void setCallBack(RpcCallback callback)
boolean isRetryImmediatelySupported()
long getResponseCellSize()
void incrementResponseCellSize(long cellSize)
long getBlockBytesScanned()
void incrementBlockBytesScanned(long blockSize)
getBlockBytesScanned()
for details.long getResponseExceptionSize()
void incrementResponseExceptionSize(long exceptionSize)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.