RpcServer.Call (Apache HBase 1.4.11 API)

java.lang.Object
- org.apache.hadoop.hbase.ipc.RpcServer.Call

All Implemented Interfaces:: RpcCallContext

Enclosing class:: RpcServer

@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"})
@InterfaceStability.Evolving
public class RpcServer.Call
extends Object
implements RpcCallContext

Datastructure that holds all necessary to a method invocation and then afterward, carries the result.

Field Summary

Fields
Modifier and Type	Field and Description
`protected CellScanner`	`cellScanner`
`protected RpcServer.Connection`	`connection`
`protected long`	`deadline`
`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`	`startTime`
`protected int`	`timeout`
`protected long`	`timestamp`
`protected org.apache.htrace.TraceInfo`	`tinfo`

Method Summary

Methods
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()`
`long`	`getDeadline()` Return the deadline of this call.
`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`	`getResponseExceptionSize()`
`long`	`getSize()`
`boolean`	`hasPriority()`
`void`	`incrementResponseBlockSize(long blockSize)`
`void`	`incrementResponseCellSize(long cellSize)` Add on the given amount to the retained cell size.
`void`	`incrementResponseExceptionSize(long exSize)`
`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()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - id
```
protected int id
```
  - service
```
protected com.google.protobuf.BlockingService service
```
  - md
```
protected com.google.protobuf.Descriptors.MethodDescriptor md
```
  - header
```
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader header
```
  - param
```
protected com.google.protobuf.Message param
```
  - cellScanner
```
protected CellScanner cellScanner
```
  - connection
```
protected RpcServer.Connection connection
```
  - timestamp
```
protected long timestamp
```
  - timeout
```
protected int timeout
```
  - startTime
```
protected long startTime
```
  - deadline
```
protected long deadline
```
  - response
```
protected org.apache.hadoop.hbase.ipc.BufferChain response
```
    Chain of buffers to send as response.
  - responder
```
protected RpcServer.Responder responder
```
  - size
```
protected long size
```
  - isError
```
protected boolean isError
```
  - tinfo
```
protected org.apache.htrace.TraceInfo tinfo
```
- Method Detail
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - getHeader
```
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader getHeader()
```
  - hasPriority
```
public boolean hasPriority()
```
  - getPriority
```
public int getPriority()
```
  - setSaslTokenResponse
```
protected void setSaslTokenResponse(ByteBuffer response)
```
  - setResponse
```
protected void setResponse(Object m,
               CellScanner cells,
               Throwable t,
               String errorMsg)
```
  - isClientCellBlockSupported
```
public boolean isClientCellBlockSupported()
```
    Description copied from interface: RpcCallContext
    
    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.
    
    Specified by:
    
    isClientCellBlockSupported in interface RpcCallContext
    
    Returns:
    True if the client supports cellblocks, else return all content in pb
  - disconnectSince
```
public long disconnectSince()
```
    Description copied from interface: RpcCallContext
    
    Check if the caller who made this IPC call has disconnected. If called from outside the context of IPC, this does nothing.
    
    Specified by:
    
    disconnectSince in interface RpcCallContext
    
    Returns:
    < 0 if the caller is still connected. The time in ms since the disconnection otherwise
  - getResponseExceptionSize
```
public long getResponseExceptionSize()
```
    Specified by:
    
    getResponseExceptionSize in interface RpcCallContext
  - incrementResponseExceptionSize
```
public void incrementResponseExceptionSize(long exSize)
```
    Specified by:
    
    incrementResponseExceptionSize in interface RpcCallContext
  - getSize
```
public long getSize()
```
  - getResponseCellSize
```
public long getResponseCellSize()
```
    Description copied from interface: RpcCallContext
    
    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
    
    Specified by:
    
    getResponseCellSize in interface RpcCallContext
  - incrementResponseCellSize
```
public void incrementResponseCellSize(long cellSize)
```
    Description copied from interface: RpcCallContext
    
    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.
    
    Specified by:
    
    incrementResponseCellSize in interface RpcCallContext
  - getResponseBlockSize
```
public long getResponseBlockSize()
```
    Specified by:
    
    getResponseBlockSize in interface RpcCallContext
  - incrementResponseBlockSize
```
public void incrementResponseBlockSize(long blockSize)
```
    Specified by:
    
    incrementResponseBlockSize in interface RpcCallContext
  - getDeadline
```
public long getDeadline()
```
    Description copied from interface: RpcCallContext
    
    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.
    
    Specified by:
    
    getDeadline in interface RpcCallContext
    
    Returns:
    The system timestamp of deadline.
  - sendResponseIfReady
```
public void sendResponseIfReady()
                         throws IOException
```
    Throws:
    
    IOException
  - getRemoteUser
```
public org.apache.hadoop.security.UserGroupInformation getRemoteUser()
```
  - getRequestUser
```
public User getRequestUser()
```
    Description copied from interface: RpcCallContext
    
    Returns the user credentials associated with the current RPC request or null if no credentials were provided.
    
    Specified by:
    
    getRequestUser in interface RpcCallContext
    
    Returns:
    A User
  - getRequestUserName
```
public String getRequestUserName()
```
    Specified by:
    
    getRequestUserName in interface RpcCallContext
    
    Returns:
    Current request's user name or null if none ongoing.
  - getRemoteAddress
```
public InetAddress getRemoteAddress()
```
    Specified by:
    
    getRemoteAddress in interface RpcCallContext
    
    Returns:
    Address of remote client if a request is ongoing, else null
  - getClientVersionInfo
```
public org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.VersionInfo getClientVersionInfo()
```
    Specified by:
    
    getClientVersionInfo in interface RpcCallContext
    
    Returns:
    the client version info, or null if the information is not present
  - isRetryImmediatelySupported
```
public boolean isRetryImmediatelySupported()
```
    Specified by:
    
    isRetryImmediatelySupported in interface RpcCallContext

Class RpcServer.Call

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

id

service

md

header

param

cellScanner

connection

timestamp

timeout

startTime

deadline

response

responder

size

isError

tinfo

Method Detail

toString

getHeader

hasPriority

getPriority

setSaslTokenResponse

setResponse

isClientCellBlockSupported

disconnectSince

getResponseExceptionSize

incrementResponseExceptionSize

getSize

getResponseCellSize

incrementResponseCellSize

getResponseBlockSize

incrementResponseBlockSize

getDeadline

sendResponseIfReady

getRemoteUser

getRequestUser

getRequestUserName

getRemoteAddress

getClientVersionInfo

isRetryImmediatelySupported