HBaseRpcControllerImpl (Apache HBase 1.4.11 API)

java.lang.Object
- org.apache.hadoop.hbase.ipc.HBaseRpcControllerImpl

All Implemented Interfaces:

com.google.protobuf.RpcController, CellScannable, HBaseRpcController
```
@InterfaceAudience.Private
public class HBaseRpcControllerImpl
extends Object
implements HBaseRpcController
```
Optionally carries Cells across the proxy/service interface down into ipc. On its way out it optionally carries a set of result Cell data. We stick the Cells here when we want to avoid having to protobuf them (for performance reasons). This class is used ferrying data across the proxy/protobuf service chasm. Also does call timeout. Used by client and server ipc'ing.

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.ipc.HBaseRpcController
  HBaseRpcController.CancellationCallback

Constructor Summary

Constructors
Constructor and Description

HBaseRpcControllerImpl()

HBaseRpcControllerImpl(CellScanner cellScanner)

HBaseRpcControllerImpl(List<CellScannable> cellIterables)

Constructors
Constructor and Description
`HBaseRpcControllerImpl()`
`HBaseRpcControllerImpl(CellScanner cellScanner)`
`HBaseRpcControllerImpl(List<CellScannable> cellIterables)`

Method Summary

Methods
Modifier and Type	Method and Description
`CellScanner`	`cellScanner()`
`String`	`errorText()`
`boolean`	`failed()`
`int`	`getCallTimeout()`
`IOException`	`getFailed()` Return the failed exception, null if not failed.
`int`	`getPriority()`
`boolean`	`hasCallTimeout()`
`boolean`	`isCanceled()`
`void`	`notifyOnCancel(com.google.protobuf.RpcCallback<Object> callback)` A little different from the basic RpcController: You can register multiple callbacks to an `HBaseRpcController`. The callback will not be called if the rpc call is finished without any cancellation. You can call me at client side also.
`void`	`notifyOnCancel(com.google.protobuf.RpcCallback<Object> callback, HBaseRpcController.CancellationCallback action)` If not cancelled, add the callback to cancellation callback list.
`void`	`reset()`
`void`	`setCallTimeout(int callTimeout)`
`void`	`setCellScanner(CellScanner cellScanner)` Only used to send cells to rpc server, the returned cells should be set by `HBaseRpcController.setDone(CellScanner)`.
`void`	`setDone(CellScanner cellScanner)` IMPORTANT: always call this method if the call finished without any exception to tell the `HBaseRpcController` that we are done.
`void`	`setFailed(IOException e)` Set failed with an exception to pass on.
`void`	`setFailed(String reason)`
`void`	`setPriority(int priority)`
`void`	`setPriority(TableName tn)`
`void`	`startCancel()`

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

- Constructor Detail
  - HBaseRpcControllerImpl
```
public HBaseRpcControllerImpl()
```
  - HBaseRpcControllerImpl
```
public HBaseRpcControllerImpl(CellScanner cellScanner)
```
  - HBaseRpcControllerImpl
```
public HBaseRpcControllerImpl(List<CellScannable> cellIterables)
```
- Method Detail
  - cellScanner
```
public CellScanner cellScanner()
```
    Specified by:
    
    cellScanner in interface CellScannable
    
    Returns:
    One-shot cell scanner (you cannot back it up and restart)
  - setCellScanner
```
public void setCellScanner(CellScanner cellScanner)
```
    Description copied from interface: HBaseRpcController
    
    Only used to send cells to rpc server, the returned cells should be set by HBaseRpcController.setDone(CellScanner).
    
    Specified by:
    
    setCellScanner in interface HBaseRpcController
  - setPriority
```
public void setPriority(int priority)
```
    Specified by:
    
    setPriority in interface HBaseRpcController
    
    Parameters:
    priority - Priority for this request; should fall roughly in the range HConstants.NORMAL_QOS to HConstants.HIGH_QOS
  - setPriority
```
public void setPriority(TableName tn)
```
    Specified by:
    
    setPriority in interface HBaseRpcController
    
    Parameters:
    tn - Set priority based off the table we are going against.
  - getPriority
```
public int getPriority()
```
    Specified by:
    
    getPriority in interface HBaseRpcController
    
    Returns:
    The priority of this request
  - reset
```
public void reset()
```
    Specified by:
    
    reset in interface com.google.protobuf.RpcController
  - getCallTimeout
```
public int getCallTimeout()
```
    Specified by:
    
    getCallTimeout in interface HBaseRpcController
  - setCallTimeout
```
public void setCallTimeout(int callTimeout)
```
    Specified by:
    
    setCallTimeout in interface HBaseRpcController
  - hasCallTimeout
```
public boolean hasCallTimeout()
```
    Specified by:
    
    hasCallTimeout in interface HBaseRpcController
  - errorText
```
public String errorText()
```
    Specified by:
    
    errorText in interface com.google.protobuf.RpcController
  - failed
```
public boolean failed()
```
    Specified by:
    
    failed in interface com.google.protobuf.RpcController
  - isCanceled
```
public boolean isCanceled()
```
    Specified by:
    
    isCanceled in interface com.google.protobuf.RpcController
  - notifyOnCancel
```
public void notifyOnCancel(com.google.protobuf.RpcCallback<Object> callback)
```
    Description copied from interface: HBaseRpcController
    A little different from the basic RpcController:
    1. You can register multiple callbacks to an HBaseRpcController.
    2. The callback will not be called if the rpc call is finished without any cancellation.
    3. You can call me at client side also.
    Specified by:
    
    notifyOnCancel in interface com.google.protobuf.RpcController
    
    Specified by:
    
    notifyOnCancel in interface HBaseRpcController
  - setFailed
```
public void setFailed(String reason)
```
    Specified by:
    
    setFailed in interface com.google.protobuf.RpcController
  - setFailed
```
public void setFailed(IOException e)
```
    Description copied from interface: HBaseRpcController
    
    Set failed with an exception to pass on. For use in async rpc clients
    
    Specified by:
    
    setFailed in interface HBaseRpcController
    
    Parameters:
    e - exception to set with
  - getFailed
```
public IOException getFailed()
```
    Description copied from interface: HBaseRpcController
    
    Return the failed exception, null if not failed.
    
    Specified by:
    
    getFailed in interface HBaseRpcController
  - setDone
```
public void setDone(CellScanner cellScanner)
```
    Description copied from interface: HBaseRpcController
    
    IMPORTANT: always call this method if the call finished without any exception to tell the HBaseRpcController that we are done.
    
    Specified by:
    
    setDone in interface HBaseRpcController
  - startCancel
```
public void startCancel()
```
    Specified by:
    
    startCancel in interface com.google.protobuf.RpcController
  - notifyOnCancel
```
public void notifyOnCancel(com.google.protobuf.RpcCallback<Object> callback,
                  HBaseRpcController.CancellationCallback action)
                    throws IOException
```
    Description copied from interface: HBaseRpcController
    
    If not cancelled, add the callback to cancellation callback list. And then execute the action with the cancellation state as a parameter. The implementation should guarantee that the cancellation state does not change during this call.
    
    Specified by:
    
    notifyOnCancel in interface HBaseRpcController
    
    Throws:
    
    IOException

Class HBaseRpcControllerImpl

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.ipc.HBaseRpcController

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

HBaseRpcControllerImpl

HBaseRpcControllerImpl

HBaseRpcControllerImpl

Method Detail

cellScanner

setCellScanner

setPriority

setPriority

getPriority

reset

getCallTimeout

setCallTimeout

hasCallTimeout

errorText

failed

isCanceled

notifyOnCancel

setFailed

setFailed

getFailed

setDone

startCancel

notifyOnCancel