Class RemoteProcedureDispatcher<TEnv,TRemote extends Comparable<TRemote>>

java.lang.Object
org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<TEnv,TRemote>
Direct Known Subclasses:
RSProcedureDispatcher

@Private public abstract class RemoteProcedureDispatcher<TEnv,TRemote extends Comparable<TRemote>> extends Object
A procedure dispatcher that aggregates and sends after elapsed time or after we hit count threshold. Creates its own threadpool to run RPCs with timeout.
  • Each server queue has a dispatch buffer
  • Once the dispatch buffer reaches a threshold-size/time we send

Call start() and then submitTask(Runnable). When done, call stop().