Class RemoteProcedureDispatcher.BufferNode
java.lang.Object
org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject
org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainer<T>
org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainerWithTimestamp<TRemote>
org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode
- All Implemented Interfaces:
Comparable<Delayed>
,Delayed
,RemoteProcedureDispatcher.RemoteNode<TEnv,
,TRemote> DelayedUtil.DelayedWithTimeout
- Enclosing class:
- RemoteProcedureDispatcher<TEnv,
TRemote extends Comparable<TRemote>>
protected final class RemoteProcedureDispatcher.BufferNode
extends DelayedUtil.DelayedContainerWithTimestamp<TRemote>
implements RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote>
Node that contains a set of RemoteProcedures
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
void
add
(RemoteProcedureDispatcher.RemoteProcedure operation) void
dispatch()
getKey()
void
operationCompleted
(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure) toString()
Methods inherited from class org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainerWithTimestamp
getTimeout, setTimeout
Methods inherited from class org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainer
equals, getObject, hashCode
Methods inherited from class org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject
compareTo, getDelay
-
Field Details
-
operations
-
dispatchedOperations
-
-
Constructor Details
-
BufferNode
-
-
Method Details
-
getKey
- Specified by:
getKey
in interfaceRemoteProcedureDispatcher.RemoteNode<TEnv,
TRemote extends Comparable<TRemote>>
-
add
- Specified by:
add
in interfaceRemoteProcedureDispatcher.RemoteNode<TEnv,
TRemote extends Comparable<TRemote>>
-
dispatch
- Specified by:
dispatch
in interfaceRemoteProcedureDispatcher.RemoteNode<TEnv,
TRemote extends Comparable<TRemote>>
-
abortOperationsInQueue
-
operationCompleted
-
toString
- Overrides:
toString
in classDelayedUtil.DelayedContainer<TRemote extends Comparable<TRemote>>
-