@InterfaceAudience.Private public interface RpcCallContext
Modifier and Type | Method and Description |
---|---|
long |
disconnectSince()
Check if the caller who made this IPC call has disconnected.
|
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 |
getResponseBlockSize() |
long |
getResponseCellSize()
The size of response cells that have been accumulated so far.
|
long |
getResponseExceptionSize() |
void |
incrementResponseBlockSize(long blockSize) |
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()
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 getResponseBlockSize()
void incrementResponseBlockSize(long blockSize)
long getResponseExceptionSize()
void incrementResponseExceptionSize(long exceptionSize)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.