org.apache.hadoop.hbase.master.procedure

Class ProcedureSyncWait.ProcedureFuture

java.lang.Object

org.apache.hadoop.hbase.master.procedure.ProcedureSyncWait.ProcedureFuture

All Implemented Interfaces:

Future<byte[]>

Enclosing class:

ProcedureSyncWait

private static class ProcedureSyncWait.ProcedureFuture
extends Object
implements Future<byte[]>

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	hasResult
private Procedure<?>	proc
private ProcedureExecutor<MasterProcedureEnv>	procExec
private byte[]	result

Constructor Summary

Constructors

Constructor and Description
ProcedureFuture(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<?> proc)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
byte[]	get()
byte[]	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Field Detail

procExec

private final ProcedureExecutor<MasterProcedureEnv> procExec

proc

private final Procedure<?> proc

hasResult

private boolean hasResult

result

private byte[] result

Constructor Detail

ProcedureFuture

public ProcedureFuture(ProcedureExecutor<MasterProcedureEnv> procExec,
                       Procedure<?> proc)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<byte[]>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<byte[]>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<byte[]>

get

public byte[] get()
           throws InterruptedException,
                  ExecutionException

Specified by:

get in interface Future<byte[]>

Throws:

InterruptedException

ExecutionException

get

public byte[] get(long timeout,
                  TimeUnit unit)
           throws InterruptedException,
                  ExecutionException,
                  TimeoutException

Specified by:

get in interface Future<byte[]>

Throws:

InterruptedException

ExecutionException

TimeoutException