org.apache.hadoop.hdfs.tools

类 DFSck

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hdfs.tools.DFSck

所有已实现的接口:

Configurable, Tool

public class DFSck
extends Configured
implements Tool

This class provides rudimentary checking of DFS volumes for errors and sub-optimal conditions.

The tool scans all files and directories, starting from an indicated root path. The following abnormal conditions are detected and handled:

• files with blocks that are completely missing from all datanodes.
  In this case the tool can perform one of the following actions:
  • none (org.apache.hadoop.hdfs.server.namenode.NamenodeFsck#FIXING_NONE)
  • move corrupted files to /lost+found directory on DFS (org.apache.hadoop.hdfs.server.namenode.NamenodeFsck#FIXING_MOVE). Remaining data blocks are saved as a block chains, representing longest consecutive series of valid blocks.
  • delete corrupted files (org.apache.hadoop.hdfs.server.namenode.NamenodeFsck#FIXING_DELETE)
• detect files with under-replicated or over-replicated blocks

Additionally, the tool collects a detailed overall DFS statistics, and optionally can print detailed statistics on block locations and replication factors of each file. The tool also provides and option to filter open files during the scan.

构造器概要

构造器

构造器和说明
DFSck(Configuration conf) Filesystem checker.

方法概要

方法

限定符和类型	方法和说明
static void	main(String[] args)
int	run(String[] args) Execute the command with the given arguments.

从类继承的方法 org.apache.hadoop.conf.Configured

getConf, setConf

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

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

从接口继承的方法 org.apache.hadoop.conf.Configurable

getConf, setConf

构造器详细资料

DFSck

public DFSck(Configuration conf)
      throws IOException

Filesystem checker.

参数:

conf - current Configuration

抛出:

IOException

方法详细资料

run

public int run(String[] args)
        throws IOException

从接口复制的说明: Tool

Execute the command with the given arguments.

指定者:

run 在接口中 Tool

参数:

args -

返回:

exit code.

抛出:

IOException

main

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

抛出:

Exception