Package | Description |
---|---|
org.apache.hadoop.ipc |
Tools to help define network clients and servers.
|
Modifier and Type | Class and Description |
---|---|
class |
DecayRpcScheduler
The decay RPC scheduler counts incoming requests in a map, then
decays the counts at a fixed time interval.
|
class |
DefaultRpcScheduler
No op default RPC scheduler.
|
Modifier and Type | Method and Description |
---|---|
void |
CallQueueManager.swapQueue(Class<? extends RpcScheduler> schedulerClass,
Class<? extends BlockingQueue<E>> queueClassToUse,
int maxSize,
String ns,
Configuration conf)
Replaces active queue with the newly requested one and transfers
all calls to the newQ before returning.
|
Constructor and Description |
---|
CallQueueManager(Class<? extends BlockingQueue<E>> backingClass,
Class<? extends RpcScheduler> schedulerClass,
boolean clientBackOffEnabled,
int maxQueueSize,
String namespace,
Configuration conf) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.