Method Detail

• disconnectSince

  long disconnectSince()

  Check if the caller who made this IPC call has disconnected. If called from outside the context of IPC, this does nothing.

  Returns:

  < 0 if the caller is still connected. The time in ms since the disconnection otherwise

• isClientCellBlockSupported

  boolean isClientCellBlockSupported()

  If the client connected and specified a codec to use, then we will use this codec making cellblocks to return. If the client did not specify a codec, we assume it does not support cellblocks and will return all content protobuf'd (though it makes our serving slower). We need to ask this question per call because a server could be hosting both clients that support cellblocks while fielding requests from clients that do not.

  Returns:

  True if the client supports cellblocks, else return all content in pb

• getRequestUser

  User getRequestUser()

  Returns the user credentials associated with the current RPC request or null if no credentials were provided.

  Returns:

  A User

• getRequestUserName

  String getRequestUserName()

  Returns:

  Current request's user name or null if none ongoing.

• getRemoteAddress

  InetAddress getRemoteAddress()

  Returns:

  Address of remote client if a request is ongoing, else null

• getClientVersionInfo

  org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.VersionInfo getClientVersionInfo()

  Returns:

  the client version info, or null if the information is not present

• isRetryImmediatelySupported

  boolean isRetryImmediatelySupported()

• getResponseCellSize

  long getResponseCellSize()

  The size of response cells that have been accumulated so far. This along with the corresponding increment call is used to ensure that multi's or scans dont get too excessively large

• incrementResponseCellSize

  void incrementResponseCellSize(long cellSize)

  Add on the given amount to the retained cell size. This is not thread safe and not synchronized at all. If this is used by more than one thread then everything will break. Since this is called for every row synchronization would be too onerous.

• getResponseBlockSize

  long getResponseBlockSize()

• incrementResponseBlockSize

  void incrementResponseBlockSize(long blockSize)

• getResponseExceptionSize

  long getResponseExceptionSize()

• incrementResponseExceptionSize

  void incrementResponseExceptionSize(long exceptionSize)

• getDeadline

  long getDeadline()

  Return the deadline of this call. If we can not complete this call in time, we can throw a TimeoutIOException and RPCServer will drop it.

  Returns:

  The system timestamp of deadline.