org.apache.hadoop.hdfs.util

类 DataTransferThrottler

java.lang.Object

org.apache.hadoop.hdfs.util.DataTransferThrottler

public class DataTransferThrottler
extends Object

a class to throttle the data transfers. This class is thread safe. It can be shared by multiple threads. The parameter bandwidthPerSec specifies the total bandwidth shared by threads.

构造器概要

构造器

构造器和说明
DataTransferThrottler(long bandwidthPerSec) Constructor
DataTransferThrottler(long period, long bandwidthPerSec) Constructor

方法概要

方法

限定符和类型	方法和说明
long	getBandwidth()
void	setBandwidth(long bytesPerSecond) Sets throttle bandwidth.
void	throttle(long numOfBytes) Given the numOfBytes sent/received since last time throttle was called, make the current thread sleep if I/O rate is too fast compared to the given bandwidth.

从类继承的方法 java.lang.Object

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

构造器详细资料

DataTransferThrottler

public DataTransferThrottler(long bandwidthPerSec)

Constructor

参数:

bandwidthPerSec - bandwidth allowed in bytes per second.

DataTransferThrottler

public DataTransferThrottler(long period,
                     long bandwidthPerSec)

Constructor

参数:

period - in milliseconds. Bandwidth is enforced over this period.

bandwidthPerSec - bandwidth allowed in bytes per second.

方法详细资料

getBandwidth

public long getBandwidth()

返回:

current throttle bandwidth in bytes per second.

setBandwidth

public void setBandwidth(long bytesPerSecond)

Sets throttle bandwidth. This takes affect latest by the end of current period.

参数:

bytesPerSecond -

throttle

public void throttle(long numOfBytes)

Given the numOfBytes sent/received since last time throttle was called, make the current thread sleep if I/O rate is too fast compared to the given bandwidth.

参数:

numOfBytes - number of bytes sent/received since last time throttle was called