org.apache.hadoop.fs

类 DU

java.lang.Object

org.apache.hadoop.util.Shell

org.apache.hadoop.fs.DU

public class DU
extends Shell

Filesystem disk space usage statistics. Uses the unix 'du' program

嵌套类概要

从类继承的嵌套类/接口 org.apache.hadoop.util.Shell

Shell.ExitCodeException, Shell.ShellCommandExecutor

字段概要

从类继承的字段 org.apache.hadoop.util.Shell

LOG, SET_GROUP_COMMAND, SET_OWNER_COMMAND, SET_PERMISSION_COMMAND, timeOutInterval, ULIMIT_COMMAND, USER_NAME_COMMAND, WINDOWS

构造器概要

构造器

构造器和说明
DU(File path, Configuration conf) Keeps track of disk usage.
DU(File path, long interval) Keeps track of disk usage.

方法概要

方法

限定符和类型	方法和说明
void	decDfsUsed(long value) Decrease how much disk space we use.
String	getDirPath()
protected String[]	getExecString() return an array containing the command name & its parameters
long	getUsed()
void	incDfsUsed(long value) Increase how much disk space we use.
static void	main(String[] args)
protected void	parseExecResult(BufferedReader lines) Parse the execution result
void	shutdown() Shut down the refreshing thread.
void	start() Start the disk usage checking thread.
String	toString()

从类继承的方法 org.apache.hadoop.util.Shell

execCommand, execCommand, execCommand, getExitCode, getGET_PERMISSION_COMMAND, getGroupsCommand, getGroupsForUserCommand, getProcess, getUlimitMemoryCommand, getUlimitMemoryCommand, getUsersForNetgroupCommand, isTimedOut, run, setEnvironment, setWorkingDirectory

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

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

构造器详细资料

DU

public DU(File path,
  long interval)
   throws IOException

Keeps track of disk usage.

参数:

path - the path to check disk usage in

interval - refresh the disk usage at this interval

抛出:

IOException - if we fail to refresh the disk usage

DU

public DU(File path,
  Configuration conf)
   throws IOException

Keeps track of disk usage.

参数:

path - the path to check disk usage in

conf - configuration object

抛出:

IOException - if we fail to refresh the disk usage

方法详细资料

decDfsUsed

public void decDfsUsed(long value)

Decrease how much disk space we use.

参数:

value - decrease by this value

incDfsUsed

public void incDfsUsed(long value)

Increase how much disk space we use.

参数:

value - increase by this value

getUsed

public long getUsed()
             throws IOException

返回:

disk space used

抛出:

IOException - if the shell command fails

getDirPath

public String getDirPath()

返回:

the path of which we're keeping track of disk usage

start

public void start()

Start the disk usage checking thread.

shutdown

public void shutdown()

Shut down the refreshing thread.

toString

public String toString()

覆盖:

toString 在类中 Object

getExecString

protected String[] getExecString()

从类复制的说明: Shell

return an array containing the command name & its parameters

指定者:

getExecString 在类中 Shell

parseExecResult

protected void parseExecResult(BufferedReader lines)
                        throws IOException

从类复制的说明: Shell

Parse the execution result

指定者:

parseExecResult 在类中 Shell

抛出:

IOException

main

public static void main(String[] args)
                 throws Exception

抛出:

Exception