org.apache.hadoop.hbase.procedure2

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BufferNode(TRemote key)

Method Summary

Modifier and Type	Method and Description
void	abortOperationsInQueue()
void	add(RemoteProcedureDispatcher.RemoteProcedure operation)
void	dispatch()
TRemote	getKey()
void	operationCompleted(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure)
String	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

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

BufferNode

protected BufferNode(TRemote key)

Method Detail

getKey

public TRemote getKey()

Specified by:

getKey in interface RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote extends Comparable<TRemote>>

add

public void add(RemoteProcedureDispatcher.RemoteProcedure operation)

Specified by:

add in interface RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote extends Comparable<TRemote>>

dispatch

public void dispatch()

Specified by:

dispatch in interface RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote extends Comparable<TRemote>>

abortOperationsInQueue

public void abortOperationsInQueue()

operationCompleted

public void operationCompleted(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure)

toString

public String toString()

Overrides:

toString in class DelayedUtil.DelayedContainer<TRemote extends Comparable<TRemote>>