org.apache.hadoop.hbase.client

Class TestRpcControllerFactory.CountingRpcController

java.lang.Object

org.apache.hadoop.hbase.ipc.DelegatingHBaseRpcController

org.apache.hadoop.hbase.client.TestRpcControllerFactory.CountingRpcController

All Implemented Interfaces:

org.apache.hadoop.hbase.CellScannable, org.apache.hadoop.hbase.ipc.HBaseRpcController, org.apache.hbase.thirdparty.com.google.protobuf.RpcController

Enclosing class:

TestRpcControllerFactory

public static class TestRpcControllerFactory.CountingRpcController
extends org.apache.hadoop.hbase.ipc.DelegatingHBaseRpcController

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.ipc.HBaseRpcController

org.apache.hadoop.hbase.ipc.HBaseRpcController.CancellationCallback

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.hbase.thirdparty.com.google.common.collect.Multiset<Integer>	GROUPED_PRIORITY
private static AtomicInteger	INT_PRIORITY
private static AtomicInteger	TABLE_PRIORITY

Constructor Summary

Constructors

Constructor and Description
CountingRpcController(org.apache.hadoop.hbase.ipc.HBaseRpcController delegate)

Method Summary

Modifier and Type	Method and Description
void	setPriority(int priority)
void	setPriority(org.apache.hadoop.hbase.TableName tn)

Methods inherited from class org.apache.hadoop.hbase.ipc.DelegatingHBaseRpcController

cellScanner, errorText, failed, getCallTimeout, getFailed, getPriority, hasCallTimeout, isCanceled, notifyOnCancel, notifyOnCancel, reset, setCallTimeout, setCellScanner, setDone, setFailed, setFailed, startCancel

Methods inherited from class java.lang.Object

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

Field Detail

GROUPED_PRIORITY

private static org.apache.hbase.thirdparty.com.google.common.collect.Multiset<Integer> GROUPED_PRIORITY

INT_PRIORITY

private static AtomicInteger INT_PRIORITY

TABLE_PRIORITY

private static AtomicInteger TABLE_PRIORITY

Constructor Detail

CountingRpcController

public CountingRpcController(org.apache.hadoop.hbase.ipc.HBaseRpcController delegate)

Method Detail

setPriority

public void setPriority(int priority)

Specified by:

setPriority in interface org.apache.hadoop.hbase.ipc.HBaseRpcController

Overrides:

setPriority in class org.apache.hadoop.hbase.ipc.DelegatingHBaseRpcController

setPriority

public void setPriority(org.apache.hadoop.hbase.TableName tn)

Specified by:

setPriority in interface org.apache.hadoop.hbase.ipc.HBaseRpcController

Overrides:

setPriority in class org.apache.hadoop.hbase.ipc.DelegatingHBaseRpcController