ScannerCallableWithReplicas (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.client.ScannerCallableWithReplicas

All Implemented Interfaces:

RetryingCallable<Result[]>
```
@InterfaceAudience.Private
 class ScannerCallableWithReplicas
extends Object
implements RetryingCallable<Result[]>
```
This class has the logic for handling scanners for regions with and without replicas. 1. A scan is attempted on the default (primary) region 2. The scanner sends all the RPCs to the default region until it is done, or, there is a timeout on the default (a timeout of zero is disallowed). 3. If there is a timeout in (2) above, scanner(s) is opened on the non-default replica(s) 4. The results from the first successful scanner are taken, and it is stored which server returned the results. 5. The next RPCs are done on the above stored server until it is done or there is a timeout, in which case, the other replicas are queried (as in (3) above).

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

(package private) class ScannerCallableWithReplicas.RetryingRPC

Nested Classes
Modifier and Type	Class and Description
`(package private) class`	`ScannerCallableWithReplicas.RetryingRPC`

Field Summary

Fields
Modifier and Type	Field and Description
`private RpcRetryingCaller<Result[]>`	`caller`
`(package private) ClusterConnection`	`cConnection`
`private org.apache.hadoop.conf.Configuration`	`conf`
`(package private) ScannerCallable`	`currentScannerCallable`
`private Result`	`lastResult`
`private static org.apache.commons.logging.Log`	`LOG`
`private Set<ScannerCallable>`	`outstandingCallables`
`protected ExecutorService`	`pool`
`(package private) AtomicBoolean`	`replicaSwitched`
`private int`	`retries`
`private Scan`	`scan`
`private int`	`scannerTimeout`
`private boolean`	`someRPCcancelled`
`private TableName`	`tableName`
`protected int`	`timeBeforeReplicas`

Constructor Summary

Constructors
Constructor and Description
`ScannerCallableWithReplicas(TableName tableName, ClusterConnection cConnection, ScannerCallable baseCallable, ExecutorService pool, int timeBeforeReplicas, Scan scan, int retries, int scannerTimeout, int caching, org.apache.hadoop.conf.Configuration conf, RpcRetryingCaller<Result[]> caller)`

Method Summary

Methods
Modifier and Type	Method and Description
`private void`	`addCallsForCurrentReplica(ResultBoundedCompletionService<Pair<Result[],ScannerCallable>> cs, RegionLocations rl)`
`private void`	`addCallsForOtherReplicas(ResultBoundedCompletionService<Pair<Result[],ScannerCallable>> cs, RegionLocations rl, int min, int max)`
`Result[]`	`call(int timeout)` Computes a result, or throws an exception if unable to do so.
`int`	`getCaching()`
`String`	`getExceptionMessageAdditionalDetail()`
`HRegionInfo`	`getHRegionInfo()`
`boolean`	`getServerHasMoreResults()`
`boolean`	`hasMoreResultsContext()`
`(package private) boolean`	`isAnyRPCcancelled()`
`boolean`	`isHeartbeatMessage()`
`void`	`prepare(boolean reload)` Prepare by setting up any connections to servers, etc., ahead of `RetryingCallable.call(int)` invocation.
`void`	`setCaching(int caching)`
`void`	`setClose()`
`void`	`setHasMoreResultsContext(boolean serverHasMoreResultsContext)`
`void`	`setRenew(boolean val)`
`void`	`setServerHasMoreResults(boolean serverHasMoreResults)`
`private void`	`setStartRowForReplicaCallable(ScannerCallable callable)` Set the start row for the replica callable based on the state of the last result received.
`long`	`sleep(long pause, int tries)`
`boolean`	`switchedToADifferentReplica()` When a scanner switches in the middle of scanning (the 'next' call fails for example), the upper layer `ClientScanner` needs to know
`void`	`throwable(Throwable t, boolean retrying)` Called when `RetryingCallable.call(int)` throws an exception and we are going to retry; take action to make it so we succeed on next call (clear caches, do relookup of locations, etc.).
`private void`	`updateCurrentlyServingReplica(ScannerCallable scanner, Result[] result, AtomicBoolean done, ExecutorService pool)`

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

Field Detail

LOG

private static final org.apache.commons.logging.Log LOG

currentScannerCallable

volatile ScannerCallable currentScannerCallable

replicaSwitched
```
AtomicBoolean replicaSwitched
```

cConnection
```
final ClusterConnection cConnection
```

pool
```
protected final ExecutorService pool
```

timeBeforeReplicas
```
protected final int timeBeforeReplicas
```

scan
```
private final Scan scan
```

retries
```
private final int retries
```

lastResult
```
private Result lastResult
```

caller

private final RpcRetryingCaller<Result[]> caller

tableName
```
private final TableName tableName
```

conf

private org.apache.hadoop.conf.Configuration conf

scannerTimeout
```
private int scannerTimeout
```

outstandingCallables

private Set<ScannerCallable> outstandingCallables

someRPCcancelled
```
private boolean someRPCcancelled
```

Constructor Detail

ScannerCallableWithReplicas

public ScannerCallableWithReplicas(TableName tableName,
                           ClusterConnection cConnection,
                           ScannerCallable baseCallable,
                           ExecutorService pool,
                           int timeBeforeReplicas,
                           Scan scan,
                           int retries,
                           int scannerTimeout,
                           int caching,
                           org.apache.hadoop.conf.Configuration conf,
                           RpcRetryingCaller<Result[]> caller)

Method Detail
- setClose
```
public void setClose()
```
- setRenew
```
public void setRenew(boolean val)
```
- setCaching
```
public void setCaching(int caching)
```
- getCaching
```
public int getCaching()
```
- getHRegionInfo
```
public HRegionInfo getHRegionInfo()
```
- getServerHasMoreResults
```
public boolean getServerHasMoreResults()
```
- setServerHasMoreResults
```
public void setServerHasMoreResults(boolean serverHasMoreResults)
```
- hasMoreResultsContext
```
public boolean hasMoreResultsContext()
```
- setHasMoreResultsContext
```
public void setHasMoreResultsContext(boolean serverHasMoreResultsContext)
```
- call
```
public Result[] call(int timeout)
              throws IOException
```
  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:
  timeout - - the time available for this call. 0 for infinite.
  
  Returns:
  computed result
  
  Throws:
  
  IOException
- updateCurrentlyServingReplica
```
private void updateCurrentlyServingReplica(ScannerCallable scanner,
                                 Result[] result,
                                 AtomicBoolean done,
                                 ExecutorService pool)
```
- switchedToADifferentReplica
```
public boolean switchedToADifferentReplica()
```
  When a scanner switches in the middle of scanning (the 'next' call fails for example), the upper layer ClientScanner needs to know
  
  Returns:
- isHeartbeatMessage
```
public boolean isHeartbeatMessage()
```
  Returns:
  true when the most recent RPC response indicated that the response was a heartbeat message. Heartbeat messages are sent back from the server when the processing of the scan request exceeds a certain time threshold. Heartbeats allow the server to avoid timeouts during long running scan operations.
- addCallsForCurrentReplica
```
private void addCallsForCurrentReplica(ResultBoundedCompletionService<Pair<Result[],ScannerCallable>> cs,
                             RegionLocations rl)
```
- addCallsForOtherReplicas
```
private void addCallsForOtherReplicas(ResultBoundedCompletionService<Pair<Result[],ScannerCallable>> cs,
                            RegionLocations rl,
                            int min,
                            int max)
```
- setStartRowForReplicaCallable
```
private void setStartRowForReplicaCallable(ScannerCallable callable)
```
  Set the start row for the replica callable based on the state of the last result received.
  
  Parameters:
  callable - The callable to set the start row on
- isAnyRPCcancelled
```
boolean isAnyRPCcancelled()
```
- prepare
```
public void prepare(boolean reload)
             throws IOException
```
  Description copied from interface: RetryingCallable
  
  Prepare by setting up any connections to servers, etc., ahead of RetryingCallable.call(int) invocation.
  
  Specified by:
  
  prepare in interface RetryingCallable<Result[]>
  
  Parameters:
  reload - Set this to true if need to requery locations
  
  Throws:
  
  IOException - e
- throwable
```
public void throwable(Throwable t,
             boolean retrying)
```
  Description copied from interface: RetryingCallable
  
  Called when RetryingCallable.call(int) throws an exception and we are going to retry; take action to make it so we succeed on next call (clear caches, do relookup of locations, etc.).
  
  Specified by:
  
  throwable in interface RetryingCallable<Result[]>
  
  retrying - True if we are in retrying mode (we are not in retrying mode when max retries == 1; we ARE in retrying mode if retries > 1 even when we are the last attempt)
- getExceptionMessageAdditionalDetail
```
public String getExceptionMessageAdditionalDetail()
```
  Specified by:
  
  getExceptionMessageAdditionalDetail in interface RetryingCallable<Result[]>
  
  Returns:
  Some details from the implementation that we would like to add to a terminating exception; i.e. a fatal exception is being thrown ending retries and we might like to add more implementation-specific detail on to the exception being thrown.
- sleep
```
public long sleep(long pause,
         int tries)
```
  Specified by:
  
  sleep in interface RetryingCallable<Result[]>
  
  Returns:
  Suggestion on how much to sleep between retries

Class ScannerCallableWithReplicas

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

LOG

currentScannerCallable

replicaSwitched

cConnection

pool

timeBeforeReplicas

scan

retries

lastResult

caller

tableName

conf

scannerTimeout

outstandingCallables

someRPCcancelled

Constructor Detail

ScannerCallableWithReplicas

Method Detail

setClose

setRenew

setCaching

getCaching

getHRegionInfo

getServerHasMoreResults

setServerHasMoreResults

hasMoreResultsContext

setHasMoreResultsContext

call

updateCurrentlyServingReplica

switchedToADifferentReplica

isHeartbeatMessage

addCallsForCurrentReplica

addCallsForOtherReplicas

setStartRowForReplicaCallable

isAnyRPCcancelled

prepare

throwable

getExceptionMessageAdditionalDetail

sleep