org.apache.hadoop.fs

类 Trash

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.fs.Trash

所有已实现的接口:

Configurable

public class Trash
extends Configured

Provides a trash feature. Files are moved to a user's trash directory, a subdirectory of their home directory named ".Trash". Files are initially moved to a current sub-directory of the trash directory. Within that sub-directory their original path is preserved. Periodically one may checkpoint the current trash and remove older checkpoints. (This design permits trash management without enumeration of the full trash content, without date support in the filesystem, and without clock synchronization.)

构造器概要

构造器

构造器和说明
Trash(Configuration conf) Construct a trash can accessor.
Trash(FileSystem fs, Configuration conf) Construct a trash can accessor for the FileSystem provided.

方法概要

方法

限定符和类型	方法和说明
void	checkpoint() Create a trash checkpoint.
void	expunge() Delete old checkpoints.
Runnable	getEmptier() Return a Runnable that periodically empties the trash of all users, intended to be run by the superuser.
static void	main(String[] args) Run an emptier.
boolean	moveToTrash(Path path) Move a file or directory to the current trash directory.

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

getConf, setConf

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

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

构造器详细资料

Trash

public Trash(Configuration conf)
      throws IOException

Construct a trash can accessor.

参数:

conf - a Configuration

抛出:

IOException

Trash

public Trash(FileSystem fs,
     Configuration conf)
      throws IOException

Construct a trash can accessor for the FileSystem provided.

抛出:

IOException

方法详细资料

moveToTrash

public boolean moveToTrash(Path path)
                    throws IOException

Move a file or directory to the current trash directory.

返回:

false if the item is already in the trash or trash is disabled

抛出:

IOException

checkpoint

public void checkpoint()
                throws IOException

Create a trash checkpoint.

抛出:

IOException

expunge

public void expunge()
             throws IOException

Delete old checkpoints.

抛出:

IOException

getEmptier

public Runnable getEmptier()
                    throws IOException

Return a Runnable that periodically empties the trash of all users, intended to be run by the superuser. Only one checkpoint is kept at a time.

抛出:

IOException

main

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

Run an emptier.

抛出:

Exception