跳过导航链接
A B C D E F G H I J K L M N O P Q R S T U V W Y 

A

abort(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
The abort() call is asynchronous and each procedure must decide how to deal with it, if they want to be abortable.
abort(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Send an abort notification the specified procedure.
abort(long, boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Send an abort notification to the specified procedure.
abort(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.FailedProcedure
 
abort(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureInMemoryChore
 
abort(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
abortOperationsInQueue() - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode
 
abortPendingOperations(TRemote, Set<RemoteProcedureDispatcher.RemoteProcedure>) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
abortProcess() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureStoreListener
triggered when the store is not able to write out data.
AbstractProcedureScheduler - org.apache.hadoop.hbase.procedure2中的类
 
AbstractProcedureScheduler() - 类 的构造器org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
acquireLock(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
The user should override this method if they need a lock on an Entity.
add(RemoteProcedureDispatcher.RemoteProcedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode
 
add(RemoteProcedureDispatcher.RemoteProcedure<TEnv, TRemote>) - 接口 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteNode
 
addBack(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
addBack(Procedure) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
Inserts the specified element at the end of this queue.
addChildProcedure(Procedure<TEnvironment>...) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
Add a child procedure to execute
addChore(ProcedureInMemoryChore) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Add a chore procedure to the executor
addFront(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
addFront(Iterator<Procedure>) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
addFront(Procedure) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
Inserts the specified element at the front of this queue.
addFront(Iterator<Procedure>) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
Inserts all elements in the iterator at the front of this queue.
addNode(TRemote) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
Add a node that will be able to execute remote procedures
addOperationToNode(TRemote, RemoteProcedureDispatcher.RemoteProcedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
Add a remote rpc.
addStackIndex(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called by the RootProcedureState on procedure execution.
afterReplay(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called when the procedure is ready to be added to the queue after the loading/replay operation.
appendStrings(StringBuilder, String...) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.util.StringUtils
 

B

BadProcedureException - org.apache.hadoop.hbase.procedure2中的异常错误
 
BadProcedureException() - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.BadProcedureException
 
BadProcedureException(String) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.BadProcedureException
 
BadProcedureException(String, Throwable) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.BadProcedureException
 
BadProcedureException(Throwable) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.BadProcedureException
 
beforeReplay(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called when the procedure is loaded for replay.
BitSetNode(long, boolean) - 类 的构造器org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
BitSetNode(long, long[], long[]) - 类 的构造器org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
BitSetNode(ProcedureProtos.ProcedureStoreTracker.TrackerNode) - 类 的构造器org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
BitSetNode(ProcedureStoreTracker.BitSetNode, boolean) - 类 的构造器org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
BufferNode(TRemote) - 类 的构造器org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode
 
buildAndGroupRequestByType(TEnv, TRemote, Set<RemoteProcedureDispatcher.RemoteProcedure>) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
buildString(String...) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.util.StringUtils
 
ByteSlot - org.apache.hadoop.hbase.procedure2.util中的类
Similar to the ByteArrayOutputStream, with the exception that we can prepend an header.
ByteSlot() - 类 的构造器org.apache.hadoop.hbase.procedure2.util.ByteSlot
 

C

canGrow(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
canMerge(ProcedureStoreTracker.BitSetNode) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
CHECK_OWNER_SET_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
clear() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
Clear current state of scheduler such that it is equivalent to newly created scheduler.
clear() - 类 中的方法org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 
close() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
compareDelayed(Delayed, Delayed) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil
 
compareTo(Procedure<TEnvironment>) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
compareTo(ProcedureWALFile) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
compareTo(Delayed) - 类 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject
 
completionCleanup(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called when the procedure is marked as completed (success or rollback).
completionCleanup(Procedure) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
The procedure in execution completed.
completionCleanup(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 
contains(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
convert() - 异常错误 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureException
 
convert() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
Convert to org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureStoreTracker.TrackerNode protobuf.
convertToProcedure(ProcedureProtos.Procedure) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.ProcedureUtil
Helper to convert the protobuf procedure.
convertToProtoLockedResource(LockedResource) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.ProcedureUtil
 
convertToProtoLockType(LockType) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.ProcedureUtil
 
convertToProtoProcedure(Procedure) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.ProcedureUtil
Helper to convert the procedure to protobuf.
convertToProtoResourceType(LockedResourceType) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.ProcedureUtil
 
CorruptedWALProcedureStoreException - org.apache.hadoop.hbase.procedure2.store.wal中的异常错误
Thrown when a procedure WAL is corrupted
CorruptedWALProcedureStoreException() - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.store.wal.CorruptedWALProcedureStoreException
default constructor
CorruptedWALProcedureStoreException(String) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.store.wal.CorruptedWALProcedureStoreException
Constructor
createNonceKey(long, long) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Create a NoneKey from the specified nonceGroup and nonce.

D

DELAYED_POISON - 类 中的静态变量org.apache.hadoop.hbase.procedure2.util.DelayedUtil
POISON implementation; used to mark special state: e.g. shutdown.
DelayedContainer(T) - 类 的构造器org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainer
 
DelayedContainerWithTimestamp(T, long) - 类 的构造器org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainerWithTimestamp
 
DelayedObject() - 类 的构造器org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject
 
DelayedUtil - org.apache.hadoop.hbase.procedure2.util中的类
 
DelayedUtil.DelayedContainer<T> - org.apache.hadoop.hbase.procedure2.util中的类
 
DelayedUtil.DelayedContainerWithTimestamp<T> - org.apache.hadoop.hbase.procedure2.util中的类
Has a timeout.
DelayedUtil.DelayedObject - org.apache.hadoop.hbase.procedure2.util中的类
 
DelayedUtil.DelayedWithTimeout - org.apache.hadoop.hbase.procedure2.util中的接口
Add a timeout to a Delay
delete(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
delete(Procedure, long[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
delete(long[], int, int) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
delete(long) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
The specified procId was removed from the executor, due to completion, abort or failure.
delete(Procedure, long[]) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
The parent procedure completed.
delete(long[], int, int) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
The specified procIds were removed from the executor, due to completion, abort or failure.
delete(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
delete(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
delete(long[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
delete(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
delete(Procedure, long[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
delete(long[], int, int) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
dequeue() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
Fetch one Procedure from the queue NOTE: this method is called with the sched lock held.
dequeue() - 类 中的方法org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 
deserialize(Class<M>) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer
 
deserialize(byte[]) - 异常错误 中的静态方法org.apache.hadoop.hbase.procedure2.RemoteProcedureException
Takes a series of bytes and tries to generate an RemoteProcedureException instance for it.
deserializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called on store load to allow the user to decode the previously serialized state.
deserializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.FailedProcedure
 
deserializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureInMemoryChore
 
deserializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.SequentialProcedure
 
deserializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
dispatch() - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode
 
dispatch() - 接口 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteNode
 
DISPATCH_DELAY_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
DISPATCH_MAX_QUEUE_SIZE_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
doAcquireLock(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Internal method called by the ProcedureExecutor that starts the user-level code acquireLock().
doExecute(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Internal method called by the ProcedureExecutor that starts the user-level code execute().
doExecute(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.SequentialProcedure
 
doReleaseLock(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Internal method called by the ProcedureExecutor that starts the user-level code releaseLock().
doRollback(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Internal method called by the ProcedureExecutor that starts the user-level code rollback().
doRollback(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.SequentialProcedure
 
dump() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
dump() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 

E

elapsedTime() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
enqueue(Procedure, boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
Add the procedure to the queue.
enqueue(Procedure, boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 
equals(Object) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
equals(Object) - 类 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainer
 
EXEC_WAL_CLEANUP_ON_LOAD_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
execute(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
The main code of the procedure.
execute(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.FailedProcedure
 
execute(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureInMemoryChore
 
execute(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
executeFromState(TEnvironment, TState) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
called to perform a single step of the specified 'state' of the procedure

F

FailedProcedure() - 类 的构造器org.apache.hadoop.hbase.procedure2.ProcedureExecutor.FailedProcedure
 
FailedProcedure(long, String, User, NonceKey, IOException) - 类 的构造器org.apache.hadoop.hbase.procedure2.ProcedureExecutor.FailedProcedure
 
failIfAborted() - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
If procedure has more states then abort it otherwise procedure is finished and abort can be ignored.
fetchType(ArrayListMultimap<Class<?>, RemoteProcedureDispatcher.RemoteOperation>, Class<T>) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
finish() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormatReader
 
fromProto(ErrorHandlingProtos.ForeignExceptionMessage) - 异常错误 中的静态方法org.apache.hadoop.hbase.procedure2.RemoteProcedureException
 

G

getActiveExecutorCount() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getActiveLogs() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getActiveMaxProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
getActiveMinProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
getActiveMinProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
getActiveProcIds() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getBuffer() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.ByteSlot
 
getChildrenLatch() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getCorePoolSize() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getCorruptedLogs() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getCurrentState() - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
getCurrentStateId() - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
This method is used from test code as it cannot be assumed that state transition will happen sequentially.
getCycles() - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
getDelay(TimeUnit) - 类 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject
 
getEnd() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
getEnvironment() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getException() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getExclusiveLockOwnerProcedure() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
getExclusiveLockOwnerProcedure() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockedResource
 
getExclusiveLockOwnerProcedure() - 接口 中的方法org.apache.hadoop.hbase.procedure2.LockStatus
 
getExclusiveLockProcIdOwner() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
getExclusiveLockProcIdOwner() - 接口 中的方法org.apache.hadoop.hbase.procedure2.LockStatus
 
getFailedCounter() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureMetrics
 
getFileSystem() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getHead() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.ByteSlot
 
getHeader() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
getInitialState() - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
Return the initial state object that will be used for the first call to executeFromState().
getKeepAliveTime(TimeUnit) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getKey() - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode
 
getKey() - 接口 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteNode
 
getLastProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getLastUpdate() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getLockResource(LockedResourceType, String) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
 
getLockResource(LockedResourceType, String) - 类 中的方法org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 
getLocks() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
List lock queues.
getLocks() - 类 中的方法org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 
getLockType() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockedResource
 
getLogFilePath(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getLogId() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
getMaxProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
getMillisFromLastRoll() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getMillisToNextPeriodicRoll() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getMinProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
getNonceKey() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getNullPollCalls() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
getNumThreads() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
getNumThreads() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
 
getNumThreads() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getObject() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainer
 
getOwner() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getParentProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getPollCalls() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
getProcedure(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getProcedure(Class<T>, long) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getProcedureMetrics(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Override this method to provide procedure specific counters for submitted count, failed count and time histogram.
getProcedures() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Get procedures.
getProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getProcIdHashCode(long) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.Procedure
Get an hashcode for the specified Procedure ID
getProcName() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getProcName() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.FailedProcedure
 
getRemainingTime(TimeUnit, long) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil
 
getRemoteProcedure() - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation
 
getResourceName() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockedResource
 
getResourceType() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockedResource
 
getResult() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getResult(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getResultOrProcedure(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getRootProcedureId(Map<Long, Procedure>, Procedure<?>) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.Procedure
 
getRootProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getSharedLockCount() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
getSharedLockCount() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockedResource
 
getSharedLockCount() - 接口 中的方法org.apache.hadoop.hbase.procedure2.LockStatus
 
getSize() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
getSource() - 异常错误 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureException
 
getStackIndexes() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getStart() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
getState() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getState(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
Convert an ordinal (or state id) to an Enum (or more descriptive) state object.
getStateId(TState) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
Convert the Enum (or more descriptive) state object to an ordinal (or state id).
getStore() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
getStoreTracker() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getStream() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
getSubmittedCounter() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureMetrics
 
getSubmittedTime() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getSuspendedProcedures() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureEvent
Access to suspendedProcedures is 'synchronized' on this object, but it's fine to return it here for tests.
getSyncedEntries() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore.SyncMetrics
 
getSyncedPerSec() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore.SyncMetrics
 
getSyncMetrics() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getSyncWaitMs() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore.SyncMetrics
 
getTimeHisto() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureMetrics
 
getTimeout() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
getTimeout() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainerWithTimestamp
 
getTimeout() - 接口 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedWithTimeout
 
getTimeoutTimestamp() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Timeout of the next timeout.
getTimestamp() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
getTimestamp() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore.SyncMetrics
 
getTotalSyncedBytes() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore.SyncMetrics
 
getTracker() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
getUncaughtExceptionHandler() - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
getUpdatedMaxProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
getUpdatedMinProcId() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
getWaitingProcedures() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockedResource
 
getWALDir() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
getWorkerThreadCount() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
grow(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 

H

handleCorrupted(ProcedureStore.ProcedureIterator) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader
Called by the ProcedureStore.load() in case we have procedures not-ready to be added to the executor, which probably means they are corrupted since some information/link is missing.
hasChildren() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
hasException() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
hasExclusiveLock() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
hasExclusiveLock() - 接口 中的方法org.apache.hadoop.hbase.procedure2.LockStatus
 
hashCode() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
hashCode() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainer
 
hasLock(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
This is used in conjunction with Procedure.holdLock(Object).
hasLockAccess(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
hasLockAccess(Procedure) - 接口 中的方法org.apache.hadoop.hbase.procedure2.LockStatus
 
hasNext() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator
Returns true if the iterator has more elements.
hasOwner() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
hasParent() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
hasParentLock(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
hasParentLock(Procedure) - 接口 中的方法org.apache.hadoop.hbase.procedure2.LockStatus
 
hasRunnables() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
hasRunnables() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
 
hasTimeout() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
haveSameParent(Procedure<?>, Procedure<?>) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.Procedure
 
holdLock(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Used to keep the procedure lock even when the procedure is yielding or suspended.
humanSize(double) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.util.StringUtils
 
humanTimeDiff(long) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.util.StringUtils
 

I

incChildrenLatch() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called by the ProcedureExecutor on procedure-load to restore the latch state
insert(Procedure, Procedure[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
insert(Procedure[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
insert(Procedure, Procedure[]) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
When a procedure is submitted to the executor insert(proc, null) will be called.
insert(Procedure[]) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
Serialize a set of new procedures.
insert(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
insert(long[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
insert(long, long[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
insert(Procedure, Procedure[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
insert(Procedure[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
InvalidWALDataException(String) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat.InvalidWALDataException
 
InvalidWALDataException(Throwable) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat.InvalidWALDataException
 
isCompacted() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
isDeleted(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
isDeleted(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
If ProcedureStoreTracker.partial is false, returns state from the bitmap.
isEmpty() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
isEmpty() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
isEmpty(String) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.util.StringUtils
 
isFailed() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
isFinished() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
isFinished(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Return true if the procedure is finished.
isInitializing() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
isLocked() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
isLocked() - 接口 中的方法org.apache.hadoop.hbase.procedure2.LockStatus
 
isLockOwner(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
isLockOwner(long) - 接口 中的方法org.apache.hadoop.hbase.procedure2.LockStatus
 
isNextFinished() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator
 
isPartial() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
isProcedureOwner(long, User) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Check if the user is this procedure's owner
isReady() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureEvent
 
isRollbackSupported(TState) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
Used by the default implementation of abort() to know if the current state can be aborted and rollback can be triggered.
isRunnable() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
isRunning() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
isRunning() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
 
isRunning() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase
 
isStarted(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Return true if the procedure is started.
isSuccess() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
isUpdated() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
isUpdated(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
isUpdated() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
isWaiting() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
isYieldAfterExecutionStep(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
By default, the procedure framework/executor will try to run procedures start to finish.
isYieldAfterExecutionStep(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
isYieldBeforeExecuteFromState(TEnvironment, TState) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
By default, the executor will try ro run all the steps of the procedure start to finish.

J

join() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
join() - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 

K

killBeforeStoreUpdate - 类 中的变量org.apache.hadoop.hbase.procedure2.ProcedureExecutor.Testing
 
killIfSuspended - 类 中的变量org.apache.hadoop.hbase.procedure2.ProcedureExecutor.Testing
 

L

load(ProcedureStore.ProcedureLoader) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
load(ProcedureStore.ProcedureLoader) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
Load the Procedures in the store.
load(ProcedureStore.ProcedureIterator) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader
Called by the ProcedureStore.load() every time a set of procedures are ready to be executed.
load(Iterator<ProcedureWALFile>, ProcedureStoreTracker, ProcedureWALFormat.Loader) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
load(ProcedureStore.ProcedureLoader) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
LockAndQueue - org.apache.hadoop.hbase.procedure2中的类
Locking for mutual exclusion between procedures.
LockAndQueue() - 类 的构造器org.apache.hadoop.hbase.procedure2.LockAndQueue
 
LockedResource - org.apache.hadoop.hbase.procedure2中的类
 
LockedResource(LockedResourceType, String, LockType, Procedure<?>, int, List<Procedure<?>>) - 类 的构造器org.apache.hadoop.hbase.procedure2.LockedResource
 
LockedResourceType - org.apache.hadoop.hbase.procedure2中的枚举
 
LockStatus - org.apache.hadoop.hbase.procedure2中的接口
Interface to get status of a Lock without getting access to acquire/release lock.
LockType - org.apache.hadoop.hbase.procedure2中的枚举
 
LOG_PREFIX - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 

M

main(String[]) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALPrettyPrinter
 
markHead() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.ByteSlot
 
MASTER_PROCEDURE_LOGDIR - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
Used to construct the name of the log directory for master procedures
MAX_RETRIES_BEFORE_ROLL_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
MAX_SYNC_FAILURE_ROLL_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
merge(ProcedureStoreTracker.BitSetNode) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 

N

newProcedure(String) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.ProcedureUtil
 
next() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator
Returns the next procedure in the iteration.
NO_PROC_ID - 类 中的静态变量org.apache.hadoop.hbase.procedure2.Procedure
 
NO_TIMEOUT - 类 中的静态变量org.apache.hadoop.hbase.procedure2.Procedure
 
NoopProcedureStore - org.apache.hadoop.hbase.procedure2.store中的类
An In-Memory store that does not keep track of the procedures inserted.
NoopProcedureStore() - 类 的构造器org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 

O

OnePhaseProcedure<TEnvironment> - org.apache.hadoop.hbase.procedure2中的类
 
OnePhaseProcedure() - 类 的构造器org.apache.hadoop.hbase.procedure2.OnePhaseProcedure
 
open() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
org.apache.hadoop.hbase.procedure2 - 程序包 org.apache.hadoop.hbase.procedure2
 
org.apache.hadoop.hbase.procedure2.store - 程序包 org.apache.hadoop.hbase.procedure2.store
 
org.apache.hadoop.hbase.procedure2.store.wal - 程序包 org.apache.hadoop.hbase.procedure2.store.wal
 
org.apache.hadoop.hbase.procedure2.util - 程序包 org.apache.hadoop.hbase.procedure2.util
 

P

PERIODIC_ROLL_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
periodicExecute(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureInMemoryChore
 
periodicRollForTesting() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
poll() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
poll(long, TimeUnit) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
poll(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
poll() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
Fetch one Procedure from the queue
poll(long, TimeUnit) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
Fetch one Procedure from the queue
postSync() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureStoreListener
triggered when the store sync is completed.
Procedure<TEnvironment> - org.apache.hadoop.hbase.procedure2中的类
Base Procedure class responsible for Procedure Metadata; e.g. state, submittedTime, lastUpdate, stack-indexes, etc.
Procedure() - 类 的构造器org.apache.hadoop.hbase.procedure2.Procedure
 
Procedure.LockState - org.apache.hadoop.hbase.procedure2中的枚举
 
ProcedureAbortedException - org.apache.hadoop.hbase.procedure2中的异常错误
Thrown when a procedure is aborted
ProcedureAbortedException() - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.ProcedureAbortedException
default constructor
ProcedureAbortedException(String) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.ProcedureAbortedException
Constructor
procedureAdded(long) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.ProcedureExecutorListener
 
ProcedureDeque - org.apache.hadoop.hbase.procedure2中的类
Type class.
ProcedureDeque() - 类 的构造器org.apache.hadoop.hbase.procedure2.ProcedureDeque
 
ProcedureEvent<T> - org.apache.hadoop.hbase.procedure2中的类
Basic ProcedureEvent that contains an "object", which can be a description or a reference to the resource to wait on, and a queue for suspended procedures.
ProcedureEvent(T) - 类 的构造器org.apache.hadoop.hbase.procedure2.ProcedureEvent
 
ProcedureException - org.apache.hadoop.hbase.procedure2中的异常错误
 
ProcedureException() - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.ProcedureException
default constructor
ProcedureException(String) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.ProcedureException
Constructor
ProcedureException(Throwable) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.ProcedureException
 
ProcedureExecutor<TEnvironment> - org.apache.hadoop.hbase.procedure2中的类
Thread Pool that executes the submitted procedures.
ProcedureExecutor(Configuration, TEnvironment, ProcedureStore) - 类 的构造器org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
ProcedureExecutor(Configuration, TEnvironment, ProcedureStore, ProcedureScheduler) - 类 的构造器org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
ProcedureExecutor.FailedProcedure<TEnvironment> - org.apache.hadoop.hbase.procedure2中的类
 
ProcedureExecutor.ProcedureExecutorListener - org.apache.hadoop.hbase.procedure2中的接口
 
ProcedureExecutor.Testing - org.apache.hadoop.hbase.procedure2中的类
 
procedureFinished(long) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.ProcedureExecutorListener
 
ProcedureInMemoryChore<TEnvironment> - org.apache.hadoop.hbase.procedure2中的类
Special procedure used as a chore.
ProcedureInMemoryChore(int) - 类 的构造器org.apache.hadoop.hbase.procedure2.ProcedureInMemoryChore
 
procedureLoaded(long) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.ProcedureExecutorListener
 
ProcedureMetrics - org.apache.hadoop.hbase.procedure2中的接口
With this interface, the procedure framework provides means to collect following set of metrics per procedure type for all procedures: Count of submitted procedure instances Time histogram for successfully completed procedure instances Count of failed procedure instances Please implement this interface to return appropriate metrics.
ProcedureScheduler - org.apache.hadoop.hbase.procedure2中的接口
Keep track of the runnable procedures
ProcedureStateSerializer - org.apache.hadoop.hbase.procedure2中的接口
 
ProcedureStore - org.apache.hadoop.hbase.procedure2.store中的接口
The ProcedureStore is used by the executor to persist the state of each procedure execution.
ProcedureStore.ProcedureIterator - org.apache.hadoop.hbase.procedure2.store中的接口
An Iterator over a collection of Procedure
ProcedureStore.ProcedureLoader - org.apache.hadoop.hbase.procedure2.store中的接口
Interface passed to the ProcedureStore.load() method to handle the store-load events.
ProcedureStore.ProcedureStoreListener - org.apache.hadoop.hbase.procedure2.store中的接口
Store listener interface.
ProcedureStoreBase - org.apache.hadoop.hbase.procedure2.store中的类
Base class for ProcedureStores.
ProcedureStoreBase() - 类 的构造器org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase
 
ProcedureStoreTracker - org.apache.hadoop.hbase.procedure2.store中的类
Keeps track of live procedures.
ProcedureStoreTracker() - 类 的构造器org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
ProcedureStoreTracker.BitSetNode - org.apache.hadoop.hbase.procedure2.store中的类
A bitmap which can grow/merge with other ProcedureStoreTracker.BitSetNode (if certain conditions are met).
ProcedureStoreTracker.DeleteState - org.apache.hadoop.hbase.procedure2.store中的枚举
 
ProcedureSuspendedException - org.apache.hadoop.hbase.procedure2中的异常错误
 
ProcedureSuspendedException() - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
default constructor
ProcedureSuspendedException(String) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
Constructor
ProcedureUtil - org.apache.hadoop.hbase.procedure2中的类
Helper to convert to/from ProcedureProtos
ProcedureWALFile - org.apache.hadoop.hbase.procedure2.store.wal中的类
Describes a WAL File
ProcedureWALFile(FileSystem, FileStatus) - 类 的构造器org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
ProcedureWALFile(FileSystem, Path, ProcedureProtos.ProcedureWALHeader, long, long) - 类 的构造器org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
ProcedureWALFormat - org.apache.hadoop.hbase.procedure2.store.wal中的类
Helper class that contains the WAL serialization utils.
ProcedureWALFormat.InvalidWALDataException - org.apache.hadoop.hbase.procedure2.store.wal中的异常错误
 
ProcedureWALFormatReader - org.apache.hadoop.hbase.procedure2.store.wal中的类
Helper class that loads the procedures stored in a WAL
ProcedureWALFormatReader(ProcedureStoreTracker, ProcedureWALFormat.Loader) - 类 的构造器org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormatReader
 
ProcedureWALPrettyPrinter - org.apache.hadoop.hbase.procedure2.store.wal中的类
ProcedureWALPrettyPrinter prints the contents of a given ProcedureWAL file
ProcedureWALPrettyPrinter() - 类 的构造器org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALPrettyPrinter
 
ProcedureYieldException - org.apache.hadoop.hbase.procedure2中的异常错误
 
ProcedureYieldException() - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.ProcedureYieldException
default constructor
ProcedureYieldException(String) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.ProcedureYieldException
Constructor
processFile(Configuration, Path) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALPrettyPrinter
Reads a log file and outputs its contents.
processProcedureWALFile(ProcedureWALFile) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALPrettyPrinter
 
push(Procedure, boolean, boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 

Q

queueHasRunnables() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
Returns true if there are procedures available to process.
queueHasRunnables() - 类 中的方法org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 
queueSize() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
Returns the number of elements in this queue.
queueSize() - 类 中的方法org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 

R

read(ProcedureWALFile) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormatReader
 
readEntry(InputStream) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
readHeader(InputStream) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
readTracker() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
readTrailer() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
readTrailer(FSDataInputStream, long, long) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
recoverFileLease(FileSystem, Path) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore.LeaseRecovery
 
recoverLease() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
recoverLease() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
Acquire the lease for the procedure store.
recoverLease() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
refreshConfiguration(Configuration) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
registerListener(ProcedureExecutor.ProcedureExecutorListener) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
registerListener(ProcedureStore.ProcedureStoreListener) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
Add the listener to the notification list.
registerListener(ProcedureStore.ProcedureStoreListener) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase
 
registerNonce(NonceKey) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Register a nonce for a procedure that is going to be submitted.
releaseExclusiveLock(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
releaseLock(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
The user should override this method, and release lock if necessary.
releaseSharedLock() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
remoteCallBuild(TEnv, TRemote) - 接口 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure
 
remoteCallCompleted(TEnv, TRemote, RemoteProcedureDispatcher.RemoteOperation) - 接口 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure
 
remoteCallFailed(TEnv, TRemote, IOException) - 接口 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure
 
remoteDispatch(TRemote, Set<RemoteProcedureDispatcher.RemoteProcedure>) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
RemoteOperation(RemoteProcedureDispatcher.RemoteProcedure) - 类 的构造器org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation
 
RemoteProcedureDispatcher<TEnv,TRemote extends Comparable<TRemote>> - org.apache.hadoop.hbase.procedure2中的类
A procedure dispatcher that aggregates and sends after elapsed time or after we hit count threshold.
RemoteProcedureDispatcher(Configuration) - 类 的构造器org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
RemoteProcedureDispatcher.BufferNode - org.apache.hadoop.hbase.procedure2中的类
Node that contains a set of RemoteProcedures
RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote> - org.apache.hadoop.hbase.procedure2中的接口
Account of what procedures are running on remote node.
RemoteProcedureDispatcher.RemoteOperation - org.apache.hadoop.hbase.procedure2中的类
Data structure with reference to remote operation.
RemoteProcedureDispatcher.RemoteProcedure<TEnv,TRemote> - org.apache.hadoop.hbase.procedure2中的接口
Remote procedure reference.
RemoteProcedureException - org.apache.hadoop.hbase.procedure2中的异常错误
A RemoteProcedureException is an exception from another thread or process.
RemoteProcedureException(String, Throwable) - 异常错误 的构造器org.apache.hadoop.hbase.procedure2.RemoteProcedureException
Create a new RemoteProcedureException that can be serialized.
removeChore(ProcedureInMemoryChore) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Remove a chore procedure from the executor
removeFile(Path) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
removeInactiveLogsForTesting() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
removeNode(TRemote) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
Remove a remote node
removeResult(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Mark the specified completed procedure, as ready to remove.
removeStackIndex() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
reset() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator
Reset the Iterator by seeking to the beginning of the list.
reset() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
reset() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.ByteSlot
 
resetTo(ProcedureStoreTracker) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
Resets internal state to same as given tracker.
resetTo(ProcedureStoreTracker, boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
resetToProto(ProcedureProtos.ProcedureStoreTracker) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
resetUpdates() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
resetUpdates() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
Clears the list of updated procedure ids.
ROLL_RETRIES_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
ROLL_THRESHOLD_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
rollback(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
The code to undo what was done by the execute() code.
rollback(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.FailedProcedure
 
rollback(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureInMemoryChore
 
rollback(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
rollbackState(TEnvironment, TState) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
called to perform the rollback of the specified state
rollWriterForTesting() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
run(String[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALPrettyPrinter
Pass one or more log file names and formatting options and it will dump out a text version of the contents on stdout.

S

schedLock() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
schedUnlock() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
sendAbortProcessSignal() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase
 
sendPostSyncSignal() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase
 
SequentialProcedure<TEnvironment> - org.apache.hadoop.hbase.procedure2中的类
A SequentialProcedure describes one step in a procedure chain: -> Step 1 -> Step 2 -> Step 3 The main difference from a base Procedure is that the execute() of a SequentialProcedure will be called only once; there will be no second execute() call once the children are finished. which means once the child of a SequentialProcedure are completed the SequentialProcedure is completed too.
SequentialProcedure() - 类 的构造器org.apache.hadoop.hbase.procedure2.SequentialProcedure
 
serialize(Message) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer
 
serialize(String, Throwable) - 异常错误 中的静态方法org.apache.hadoop.hbase.procedure2.RemoteProcedureException
Converts a RemoteProcedureException to an array of bytes.
serializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
The user-level code of the procedure may have some state to persist (e.g. input arguments or current position in the processing state) to be able to resume on failure.
serializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.FailedProcedure
 
serializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureInMemoryChore
 
serializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.SequentialProcedure
 
serializeStateData(ProcedureStateSerializer) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
setAbortFailure(String, String) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
setChildrenLatch(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called by the ProcedureExecutor on procedure-load to restore the latch state
setDeleted(long, boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
setDeletedIfSet(long...) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
setDeletedIfSet(ProcedureStoreTracker) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
setFailure(String, Throwable) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
setFailure(RemoteProcedureException) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
setFailureResultForNonce(NonceKey, String, User, IOException) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
If the failure failed before submitting it, we may want to give back the same error to the requests with the same nonceKey.
setKeepAliveTime(long, TimeUnit) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
setKeepDeletes(boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
setLastUpdate(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called on store load to initialize the Procedure internals after the creation/deserialization.
setMaxProcId(long) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader
Called by ProcedureStore.load() to notify about the maximum proc-id in the store.
setNextState(TState) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
Set the next state for the procedure.
setNonceKey(NonceKey) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called by the ProcedureExecutor to set the value to the newly created procedure.
setOwner(String) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
setOwner(User) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
setParentProcId(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called by the ProcedureExecutor to assign the parent to the newly created procedure.
setPartialFlag(boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
setProcId(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called by the ProcedureExecutor to assign the ID to the newly created procedure.
setProcIds(long, long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
setResult(byte[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
The procedure may leave a "result" on completion.
setRootProcId(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
setRunning(boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase
Change the state to 'isRunning', returns true if the store state was changed, false if the store was already in that state.
setRunningProcedureCount(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
setRunningProcedureCount(int) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
Set the number of procedure running.
setRunningProcedureCount(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
setStackIndexes(List<Integer>) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called on store load to initialize the Procedure internals after the creation/deserialization.
setState(ProcedureProtos.ProcedureState) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
setSubmittedTime(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called on store load to initialize the Procedure internals after the creation/deserialization.
setTimeout(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
setTimeout(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainerWithTimestamp
 
setTimeoutFailure(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called by the ProcedureExecutor when the timeout set by setTimeout() is expired.
shouldKillBeforeStoreUpdate() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.Testing
 
shouldKillBeforeStoreUpdate(boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor.Testing
 
shouldWaitClientAck(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
By default, the executor will keep the procedure result around util the eviction TTL is expired.
signalAll() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
signalAll() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
In case the class is blocking on poll() waiting for items to be added, this method should awake poll() and poll() should return.
SimpleProcedureScheduler - org.apache.hadoop.hbase.procedure2中的类
Simple scheduler for procedures
SimpleProcedureScheduler() - 类 的构造器org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 
size() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
size() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
Returns the number of elements in this queue.
size() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.ByteSlot
 
skipNext() - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator
Skip the next procedure
start() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
start(int, boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Start the procedure executor.
start() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
Start the scheduler
start() - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
start(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
start(int) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
Start/Open the procedure store
start(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
StateMachineProcedure<TEnvironment,TState> - org.apache.hadoop.hbase.procedure2中的类
Procedure described by a series of steps.
StateMachineProcedure() - 类 的构造器org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
StateMachineProcedure.Flow - org.apache.hadoop.hbase.procedure2中的枚举
 
stop() - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
stop() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
stop() - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
Stop the scheduler
stop() - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
stop(boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
stop(boolean) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
Stop/Close the procedure store
stop(boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
STORE_WAL_SYNC_STATS_COUNT - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
StringUtils - org.apache.hadoop.hbase.procedure2.util中的类
 
submitProcedure(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Add a new root-procedure to the executor.
submitProcedure(Procedure, NonceKey) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Add a new root-procedure to the executor.
submitProcedures(Procedure[]) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Add a set of new root-procedure to the executor.
submitTask(Callable<Void>) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
submitTask(Callable<Void>, long, TimeUnit) - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
suspend() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureEvent
Mark the event as not ready.
suspendIfNotReady(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureEvent
 
SYNC_WAIT_MSEC_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
SyncMetrics() - 类 的构造器org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore.SyncMetrics
 
syncSlots(FSDataOutputStream, ByteSlot[], int, int) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
syncStream(FSDataOutputStream) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 

T

takeWithoutInterrupt(DelayQueue<E>) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil
 
Testing() - 类 的构造器org.apache.hadoop.hbase.procedure2.ProcedureExecutor.Testing
 
THREAD_POOL_SIZE_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
 
toggleKillBeforeStoreUpdate - 类 中的变量org.apache.hadoop.hbase.procedure2.ProcedureExecutor.Testing
 
toProto(String, Throwable) - 异常错误 中的静态方法org.apache.hadoop.hbase.procedure2.RemoteProcedureException
 
toProto() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
Builds org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureStoreTracker protocol buffer from current state.
toString() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
toString() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
toString() - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureEvent
 
toString() - 类 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode
 
toString() - 异常错误 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureException
 
toString() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
toString() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
toString() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainer
 
toString() - 类 中的方法org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject
 
toStringClass() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
toStringClassDetails(StringBuilder) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Extend the toString() information with the procedure details e.g. className and parameters
toStringDetails() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Extend the toString() information with more procedure details
toStringSimpleSB() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Build the StringBuilder for the simple form of procedure string.
toStringState(StringBuilder) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called from Procedure.toString() when interpolating Procedure State.
toStringState(StringBuilder) - 类 中的方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
tryExclusiveLock(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
trySharedLock() - 类 中的方法org.apache.hadoop.hbase.procedure2.LockAndQueue
 
TwoPhaseProcedure<TEnvironment> - org.apache.hadoop.hbase.procedure2中的类
 
TwoPhaseProcedure() - 类 的构造器org.apache.hadoop.hbase.procedure2.TwoPhaseProcedure
 

U

undeleteAll() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
undeleteAll() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
unregisterListener(ProcedureExecutor.ProcedureExecutorListener) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
unregisterListener(ProcedureStore.ProcedureStoreListener) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
Remove the listener from the notification list.
unregisterListener(ProcedureStore.ProcedureStoreListener) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase
 
unregisterNonceIfProcedureWasNotSubmitted(NonceKey) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureExecutor
Remove the NonceKey if the procedure was not submitted to the executor.
unsetPartialFlag() - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
unwrapRemoteException() - 异常错误 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureException
 
unwrapRemoteIOException() - 异常错误 中的方法org.apache.hadoop.hbase.procedure2.RemoteProcedureException
 
update(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore
 
update(Procedure) - 接口 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStore
The specified procedure was executed, and the new state should be written to the store.
update(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.BitSetNode
 
update(long) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker
 
update(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
updateLocalTracker(ProcedureStoreTracker) - 类 中的方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFile
 
updateMetricsOnFinish(TEnvironment, long, boolean) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
This function will be called just after procedure execution is finished.
updateMetricsOnSubmit(TEnvironment) - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
This function will be called just when procedure is submitted for execution.
updateTimestamp() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
Called by ProcedureExecutor after each time a procedure step is executed.
USE_HSYNC_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 

V

validateClass(Procedure) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.ProcedureUtil
 
valueOf(String) - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.LockedResourceType
返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.LockType
返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.Procedure.LockState
返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.DeleteState
返回带有指定名称的该类型的枚举常量。
values() - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.LockedResourceType
按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。
values() - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.LockType
按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。
values() - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.Procedure.LockState
按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。
values() - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。
values() - 枚举 中的静态方法org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker.DeleteState
按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

W

WAIT_BEFORE_ROLL_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
waitProcedure(ProcedureDeque, Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
wake(AbstractProcedureScheduler) - 类 中的方法org.apache.hadoop.hbase.procedure2.ProcedureEvent
Wakes up the suspended procedures by pushing them back into scheduler queues and sets the event as ready.
wakeEvents(AbstractProcedureScheduler, ProcedureEvent...) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.ProcedureEvent
Wakes up all the given events and puts the procedures waiting on them back into ProcedureScheduler queues.
wakePollIfNeeded(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
wakeProcedure(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
 
wakeWaitingProcedures(ProcedureDeque) - 类 中的方法org.apache.hadoop.hbase.procedure2.AbstractProcedureScheduler
Wakes up given waiting procedures by pushing them back into scheduler queues.
WAL_COUNT_WARN_THRESHOLD_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
WALProcedureStore - org.apache.hadoop.hbase.procedure2.store.wal中的类
WAL implementation of the ProcedureStore.
WALProcedureStore(Configuration, WALProcedureStore.LeaseRecovery) - 类 的构造器org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
WALProcedureStore(Configuration, Path, Path, WALProcedureStore.LeaseRecovery) - 类 的构造器org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
 
WALProcedureStore.LeaseRecovery - org.apache.hadoop.hbase.procedure2.store.wal中的接口
 
WALProcedureStore.SyncMetrics - org.apache.hadoop.hbase.procedure2.store.wal中的类
 
wasExecuted() - 类 中的方法org.apache.hadoop.hbase.procedure2.Procedure
 
WORKER_KEEP_ALIVE_TIME_CONF_KEY - 类 中的静态变量org.apache.hadoop.hbase.procedure2.ProcedureExecutor
 
write(int) - 类 中的方法org.apache.hadoop.hbase.procedure2.util.ByteSlot
 
write(byte[], int, int) - 类 中的方法org.apache.hadoop.hbase.procedure2.util.ByteSlot
 
writeAt(int, int) - 类 中的方法org.apache.hadoop.hbase.procedure2.util.ByteSlot
 
writeDelete(ByteSlot, long) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
writeDelete(ByteSlot, Procedure, long[]) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
writeEntry(ByteSlot, ProcedureProtos.ProcedureWALEntry.Type, Procedure, Procedure[]) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
writeHeader(OutputStream, ProcedureProtos.ProcedureWALHeader) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
writeInsert(ByteSlot, Procedure) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
writeInsert(ByteSlot, Procedure, Procedure[]) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
writeTo(OutputStream) - 类 中的方法org.apache.hadoop.hbase.procedure2.util.ByteSlot
 
writeTrailer(FSDataOutputStream, ProcedureStoreTracker) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 
writeUpdate(ByteSlot, Procedure) - 类 中的静态方法org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat
 

Y

yield(Procedure) - 接口 中的方法org.apache.hadoop.hbase.procedure2.ProcedureScheduler
The procedure can't run at the moment.
yield(Procedure) - 类 中的方法org.apache.hadoop.hbase.procedure2.SimpleProcedureScheduler
 
A B C D E F G H I J K L M N O P Q R S T U V W Y 
跳过导航链接

Copyright © 2007–2020. All rights reserved.