DelegatingHBaseRpcController (Apache HBase 1.4.11 API)

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

All Implemented Interfaces:

com.google.protobuf.RpcController, CellScannable, HBaseRpcController
```
@InterfaceAudience.Private
public class DelegatingHBaseRpcController
extends Object
implements HBaseRpcController
```
Simple delegating controller for use with the RpcControllerFactory to help override standard behavior of a HBaseRpcController. Used testing.

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

Constructor Summary

Constructors
Constructor and Description

DelegatingHBaseRpcController(HBaseRpcController delegate)

Constructors
Constructor and Description
`DelegatingHBaseRpcController(HBaseRpcController delegate)`

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
  - DelegatingHBaseRpcController
```
public DelegatingHBaseRpcController(HBaseRpcController delegate)
```
- Method Detail
  - reset
```
public void reset()
```
    Specified by:
    
    reset in interface com.google.protobuf.RpcController
  - failed
```
public boolean failed()
```
    Specified by:
    
    failed in interface com.google.protobuf.RpcController
  - errorText
```
public String errorText()
```
    Specified by:
    
    errorText in interface com.google.protobuf.RpcController
  - startCancel
```
public void startCancel()
```
    Specified by:
    
    startCancel in interface com.google.protobuf.RpcController
  - setFailed
```
public void setFailed(String reason)
```
    Specified by:
    
    setFailed 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
  - cellScanner
```
public CellScanner cellScanner()
```
    Specified by:
    
    cellScanner in interface CellScannable
    
    Returns:
    A CellScanner over the contained Cells
  - 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
  - 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
  - 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
  - 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 DelegatingHBaseRpcController

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

DelegatingHBaseRpcController

Method Detail

reset

failed

errorText

startCancel

setFailed

isCanceled

notifyOnCancel

cellScanner

setCellScanner

setPriority

setPriority

getPriority

getCallTimeout

setCallTimeout

hasCallTimeout

setFailed

getFailed

setDone

notifyOnCancel