RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.client.RegionServerCallable<Result>
- - org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable

All Implemented Interfaces:

Cancellable, RetryingCallable<Result>

Enclosing class:

RpcRetryingCallerWithReadReplicas
```
 class RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable
extends RegionServerCallable<Result>
implements Cancellable
```
A RegionServerCallable that takes into account the replicas, i.e. - the call can be on any replica - we need to stop retrying when the call is completed - we can be interrupted

Field Summary

Fields
Modifier and Type Field and Description

private PayloadCarryingRpcController controller

(package private) int id
- Fields inherited from class org.apache.hadoop.hbase.client.RegionServerCallable
  connection, location, row, tableName

Fields
Modifier and Type	Field and Description
`private PayloadCarryingRpcController`	`controller`
`(package private) int`	`id`

Constructor Summary

Constructors
Constructor and Description
`RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable(int id, HRegionLocation location)`

Method Summary

Methods
Modifier and Type	Method and Description
`Result`	`call(int callTimeout)` Computes a result, or throws an exception if unable to do so.
`void`	`cancel()`
`boolean`	`isCancelled()`
`void`	`prepare(boolean reload)` Two responsibilities - if the call is already completed (by another replica) stops the retries.

Methods inherited from class org.apache.hadoop.hbase.client.RegionServerCallable
getConnection, getExceptionMessageAdditionalDetail, getHRegionInfo, getLocation, getRow, getStub, getTableName, setLocation, setStub, sleep, throwable

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

- Field Detail
  - id
```
final int id
```
  - controller
```
private final PayloadCarryingRpcController controller
```
- Constructor Detail
  - RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable
```
public RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable(int id,
                                                             HRegionLocation location)
```
- Method Detail
  - cancel
```
public void cancel()
```
    Specified by:
    
    cancel in interface Cancellable
  - prepare
```
public void prepare(boolean reload)
             throws IOException
```
    Two responsibilities - if the call is already completed (by another replica) stops the retries. - set the location to the right region, depending on the replica.
    
    Specified by:
    
    prepare in interface RetryingCallable<Result>
    
    Overrides:
    
    prepare in class RegionServerCallable<Result>
    
    Parameters:
    reload - Set this to true if connection should re-find the region
    
    Throws:
    
    IOException - e
  - call
```
public Result call(int callTimeout)
            throws Exception
```
    Description copied from interface: RetryingCallable
    
    Computes a result, or throws an exception if unable to do so.
    
    Specified by:
    
    call in interface RetryingCallable<Result>
    
    Parameters:
    callTimeout - - the time available for this call. 0 for infinite.
    
    Returns:
    computed result
    
    Throws:
    
    Exception - if unable to compute a result
  - isCancelled
```
public boolean isCancelled()
```
    Specified by:
    
    isCancelled in interface Cancellable

Class RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable

Field Summary

Fields inherited from class org.apache.hadoop.hbase.client.RegionServerCallable

Constructor Summary

Method Summary

Methods inherited from class org.apache.hadoop.hbase.client.RegionServerCallable

Methods inherited from class java.lang.Object

Field Detail

id

controller

Constructor Detail

RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable

Method Detail

cancel

prepare

call

isCancelled