org.apache.hadoop.hbase.client

Class HBaseAdmin.ProcedureFuture<V>

java.lang.Object

org.apache.hadoop.hbase.client.HBaseAdmin.ProcedureFuture<V>

All Implemented Interfaces:

Future<V>

Direct Known Subclasses:

HBaseAdmin.TableFuture

Enclosing class:

HBaseAdmin

@InterfaceAudience.Private
 @InterfaceStability.Evolving
protected static class HBaseAdmin.ProcedureFuture<V>
extends Object
implements Future<V>

Future that waits on a procedure result. Returned by the async version of the Admin calls, and used internally by the sync calls to wait on the result of the procedure.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	HBaseAdmin.ProcedureFuture.WaitForStateCallable

Constructor Summary

Constructors

Constructor and Description
ProcedureFuture(HBaseAdmin admin, Long procId)

Method Summary

Modifier and Type	Method and Description
protected MasterProtos.AbortProcedureResponse	abortProcedureResult(MasterProtos.AbortProcedureRequest request)
boolean	cancel(boolean mayInterruptIfRunning)
protected V	convertResult(MasterProtos.GetProcedureResultResponse response) Convert the procedure result response to a specified type.
V	get()
V	get(long timeout, TimeUnit unit)
protected HBaseAdmin	getAdmin()
protected MasterProtos.GetProcedureResultResponse	getProcedureResult(MasterProtos.GetProcedureResultRequest request)
boolean	isCancelled()
boolean	isDone()
protected V	postOpeartionFailure(IOException exception, long deadlineTs) Called after the operation is terminated with a failure.
protected V	postOperationFailure(IOException exception, long deadlineTs) Called after the operation is terminated with a failure.
protected V	postOperationResult(V result, long deadlineTs) Called after the operation is completed and the result fetched.
protected void	waitForState(long deadlineTs, HBaseAdmin.ProcedureFuture.WaitForStateCallable callable)
protected V	waitOperationResult(long deadlineTs) Fallback implementation in case the procedure is not supported by the server.

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcedureFuture

public ProcedureFuture(HBaseAdmin admin,
                       Long procId)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

abortProcedureResult

protected MasterProtos.AbortProcedureResponse abortProcedureResult(MasterProtos.AbortProcedureRequest request)
                                                            throws IOException

Throws:

IOException

get

public V get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

get

public V get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

TimeoutException

isDone

public boolean isDone()

Specified by:

isDone in interface Future<V>

getAdmin

protected HBaseAdmin getAdmin()

getProcedureResult

protected MasterProtos.GetProcedureResultResponse getProcedureResult(MasterProtos.GetProcedureResultRequest request)
                                                              throws IOException

Throws:

IOException

convertResult

protected V convertResult(MasterProtos.GetProcedureResultResponse response)
                   throws IOException

Convert the procedure result response to a specified type.

Parameters:

response - the procedure result object to parse

Returns:

the result data of the procedure.

Throws:

IOException

waitOperationResult

protected V waitOperationResult(long deadlineTs)
                         throws IOException,
                                TimeoutException

Fallback implementation in case the procedure is not supported by the server. It should try to wait until the operation is completed.

Parameters:

deadlineTs - the timestamp after which this method should throw a TimeoutException

Returns:

the result data of the operation

Throws:

IOException

TimeoutException

postOperationResult

protected V postOperationResult(V result,
                                long deadlineTs)
                         throws IOException,
                                TimeoutException

Called after the operation is completed and the result fetched. this allows to perform extra steps after the procedure is completed. it allows to apply transformations to the result that will be returned by get().

Parameters:

result - the result of the procedure

deadlineTs - the timestamp after which this method should throw a TimeoutException

Returns:

the result of the procedure, which may be the same as the passed one

Throws:

IOException

TimeoutException

postOperationFailure

protected V postOperationFailure(IOException exception,
                                 long deadlineTs)
                          throws IOException,
                                 TimeoutException

Called after the operation is terminated with a failure. this allows to perform extra steps after the procedure is terminated. it allows to apply transformations to the result that will be returned by get(). The default implementation will rethrow the exception

Parameters:

exception - the exception got from fetching the result

deadlineTs - the timestamp after which this method should throw a TimeoutException

Returns:

the result of the procedure, which may be the same as the passed one

Throws:

IOException

TimeoutException

postOpeartionFailure

protected V postOpeartionFailure(IOException exception,
                                 long deadlineTs)
                          throws IOException,
                                 TimeoutException

Called after the operation is terminated with a failure. this allows to perform extra steps after the procedure is terminated. it allows to apply transformations to the result that will be returned by get(). The default implementation will rethrow the exception

Parameters:

exception - the exception got from fetching the result

deadlineTs - the timestamp after which this method should throw a TimeoutException

Returns:

the result of the procedure, which may be the same as the passed one

Throws:

IOException

TimeoutException

waitForState

protected void waitForState(long deadlineTs,
                            HBaseAdmin.ProcedureFuture.WaitForStateCallable callable)
                     throws IOException,
                            TimeoutException

Throws:

IOException

TimeoutException