org.apache.hadoop.hbase.client

Class HBaseAdmin.ProcedureFuture<V>

java.lang.Object

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

All Implemented Interfaces:

java.util.concurrent.Future<V>

Direct Known Subclasses:

HBaseAdmin.TableFuture

Enclosing class:

HBaseAdmin

@InterfaceAudience.Private
 @InterfaceStability.Evolving
protected static class HBaseAdmin.ProcedureFuture<V>
extends java.lang.Object
implements java.util.concurrent.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, java.lang.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, java.util.concurrent.TimeUnit unit)
protected HBaseAdmin	getAdmin()
protected MasterProtos.GetProcedureResultResponse	getProcedureResult(MasterProtos.GetProcedureResultRequest request)
boolean	isCancelled()
boolean	isDone()
protected V	postOpeartionFailure(java.io.IOException exception, long deadlineTs) Called after the operation is terminated with a failure.
protected V	postOperationFailure(java.io.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,
                       java.lang.Long procId)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<V>

abortProcedureResult

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

Throws:

java.io.IOException

get

public V get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<V>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public V get(long timeout,
             java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<V>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<V>

getAdmin

protected HBaseAdmin getAdmin()

getProcedureResult

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

Throws:

java.io.IOException

convertResult

protected V convertResult(MasterProtos.GetProcedureResultResponse response)
                   throws java.io.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:

java.io.IOException

waitOperationResult

protected V waitOperationResult(long deadlineTs)
                         throws java.io.IOException,
                                java.util.concurrent.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:

java.io.IOException

java.util.concurrent.TimeoutException

postOperationResult

protected V postOperationResult(V result,
                                long deadlineTs)
                         throws java.io.IOException,
                                java.util.concurrent.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:

java.io.IOException

java.util.concurrent.TimeoutException

postOperationFailure

protected V postOperationFailure(java.io.IOException exception,
                                 long deadlineTs)
                          throws java.io.IOException,
                                 java.util.concurrent.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:

java.io.IOException

java.util.concurrent.TimeoutException

postOpeartionFailure

protected V postOpeartionFailure(java.io.IOException exception,
                                 long deadlineTs)
                          throws java.io.IOException,
                                 java.util.concurrent.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:

java.io.IOException

java.util.concurrent.TimeoutException

waitForState

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

Throws:

java.io.IOException

java.util.concurrent.TimeoutException