org.apache.hadoop.hbase.client

Class ScannerCallableWithReplicas.RetryingRPC

java.lang.Object

org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.RetryingRPC

All Implemented Interfaces:

Cancellable, RetryingCallable<Pair<Result[],ScannerCallable>>

Enclosing class:

ScannerCallableWithReplicas

class ScannerCallableWithReplicas.RetryingRPC
extends Object
implements RetryingCallable<Pair<Result[],ScannerCallable>>, Cancellable

Field Summary

Fields

Modifier and Type	Field and Description
(package private) ScannerCallable	callable
(package private) RpcRetryingCaller<Result[]>	caller
private boolean	cancelled

Constructor Summary

Constructors

Constructor and Description
RetryingRPC(ScannerCallable callable)

Method Summary

Modifier and Type	Method and Description
Pair<Result[],ScannerCallable>	call(int callTimeout) Computes a result, or throws an exception if unable to do so.
void	cancel()
String	getExceptionMessageAdditionalDetail()
boolean	isCancelled()
void	prepare(boolean reload) Prepare by setting up any connections to servers, etc., ahead of call invocation.
long	sleep(long pause, int tries)
void	throwable(Throwable t, boolean retrying) Called when call 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.).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

callable

final ScannerCallable callable

caller

RpcRetryingCaller<Result[]> caller

cancelled

private volatile boolean cancelled

Constructor Detail

RetryingRPC

RetryingRPC(ScannerCallable callable)

Method Detail

call

public Pair<Result[],ScannerCallable> call(int callTimeout)
                                    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<Pair<Result[],ScannerCallable>>

Parameters:

callTimeout - - the time available for this call. 0 for infinite.

Returns:

computed result

Throws:

IOException

prepare

public void prepare(boolean reload)
             throws IOException

Description copied from interface: RetryingCallable

Prepare by setting up any connections to servers, etc., ahead of call invocation. TODO: We call prepare before EVERY call. Seems wrong. FIX!!!!

Specified by:

prepare in interface RetryingCallable<Pair<Result[],ScannerCallable>>

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 call 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<Pair<Result[],ScannerCallable>>

Parameters:

t - throwable which was thrown

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<Pair<Result[],ScannerCallable>>

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<Pair<Result[],ScannerCallable>>

Parameters:

pause - time to pause

tries - amount of tries until till sleep

Returns:

Suggestion on how much to sleep between retries

cancel

public void cancel()

Specified by:

cancel in interface Cancellable

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Cancellable