Constructor Detail

• HBaseAdmin.ProcedureFuture

  public HBaseAdmin.ProcedureFuture(HBaseAdmin admin,
                            Long procId)

• HBaseAdmin.ProcedureFuture

  public HBaseAdmin.ProcedureFuture(HBaseAdmin admin,
                            Long procId,
                            boolean waitForOpResult)

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 org.apache.hadoop.hbase.protobuf.generated.MasterProtos.AbortProcedureResponse abortProcedureResult(org.apache.hadoop.hbase.protobuf.generated.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 org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetProcedureResultResponse getProcedureResult(org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetProcedureResultRequest request)
                                                                                                           throws IOException

  Throws:

  IOException

• convertResult

  protected V convertResult(org.apache.hadoop.hbase.protobuf.generated.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

• 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