Package org.apache.hadoop.ipc

Class DefaultRpcScheduler

java.lang.Object

org.apache.hadoop.ipc.DefaultRpcScheduler

All Implemented Interfaces:

RpcScheduler

public class DefaultRpcScheduler
extends Object
implements RpcScheduler

No op default RPC scheduler.

Constructor Summary

Constructors

Constructor	Description
DefaultRpcScheduler(int priorityLevels, String namespace, Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	addResponseTime(String callName, Schedulable schedulable, ProcessingDetails details)	Store a processing time value for an RPC call into this scheduler.
int	getPriorityLevel(Schedulable obj)
boolean	shouldBackOff(Schedulable obj)
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.ipc.RpcScheduler

addResponseTime

Constructor Details

DefaultRpcScheduler

public DefaultRpcScheduler(int priorityLevels,
 String namespace,
 Configuration conf)

Method Details

getPriorityLevel

public int getPriorityLevel(Schedulable obj)

Specified by:

getPriorityLevel in interface RpcScheduler

Parameters:

obj - input obj.

Returns:

Returns priority level greater than zero as a hint for scheduling.

shouldBackOff

public boolean shouldBackOff(Schedulable obj)

Specified by:

shouldBackOff in interface RpcScheduler

addResponseTime

public void addResponseTime(String callName,
 Schedulable schedulable,
 ProcessingDetails details)

Description copied from interface: RpcScheduler

Store a processing time value for an RPC call into this scheduler.

Specified by:

addResponseTime in interface RpcScheduler

Parameters:

callName - The name of the call.

schedulable - The schedulable representing the incoming call.

details - The details of processing time.

stop

public void stop()

Specified by:

stop in interface RpcScheduler