org.apache.hadoop.fs

クラス TrashPolicy

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.fs.TrashPolicy

すべての実装されたインタフェース:

Configurable

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public abstract class TrashPolicy
extends Configured

This interface is used for implementing different Trash policies. Provides factory method to create instances of the configured Trash policy.

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
protected long	deletionInterval
protected FileSystem	fs
protected Path	trash

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
TrashPolicy()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
abstract void	createCheckpoint() Create a trash checkpoint.
abstract void	deleteCheckpoint() Delete old trash checkpoint(s).
abstract Path	getCurrentTrashDir() Get the current working directory of the Trash Policy This API does not work with files deleted from encryption zone when HDFS data encryption at rest feature is enabled as rename file between encryption zones or encryption zone and non-encryption zone is not allowed.
Path	getCurrentTrashDir(Path path) Get the current trash directory for path specified based on the Trash Policy
abstract Runnable	getEmptier() Return a Runnable that periodically empties the trash of all users, intended to be run by the superuser.
static TrashPolicy	getInstance(Configuration conf, FileSystem fs) Get an instance of the configured TrashPolicy based on the value of the configuration parameter fs.trash.classname.
void	initialize(Configuration conf, FileSystem fs) Used to setup the trash policy.
abstract boolean	isEnabled() Returns whether the Trash Policy is enabled for this filesystem.
abstract 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

フィールドの詳細

fs

protected FileSystem fs

trash

protected Path trash

deletionInterval

protected long deletionInterval

コンストラクタの詳細

TrashPolicy

public TrashPolicy()

メソッドの詳細

initialize

public void initialize(Configuration conf,
                       FileSystem fs)
                throws IOException

Used to setup the trash policy. Must be implemented by all TrashPolicy implementations. Different from initialize(conf, fs, home), this one does not assume trash always under /user/$USER due to HDFS encryption zone.

パラメータ:

conf - the configuration to be used

fs - the filesystem to be used

例外:

IOException

isEnabled

public abstract boolean isEnabled()

Returns whether the Trash Policy is enabled for this filesystem.

moveToTrash

public abstract 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

createCheckpoint

public abstract void createCheckpoint()
                               throws IOException

Create a trash checkpoint.

例外:

IOException

deleteCheckpoint

public abstract void deleteCheckpoint()
                               throws IOException

Delete old trash checkpoint(s).

例外:

IOException

getCurrentTrashDir

public abstract Path getCurrentTrashDir()

Get the current working directory of the Trash Policy This API does not work with files deleted from encryption zone when HDFS data encryption at rest feature is enabled as rename file between encryption zones or encryption zone and non-encryption zone is not allowed. The caller is recommend to use the new API TrashPolicy#getCurrentTrashDir(Path path). It returns the trash location correctly for the path specified no matter the path is in encryption zone or not.

getCurrentTrashDir

public Path getCurrentTrashDir(Path path)
                        throws IOException

Get the current trash directory for path specified based on the Trash Policy

パラメータ:

path - path to be deleted

戻り値:

current trash directory for the path to be deleted

例外:

IOException

getEmptier

public abstract Runnable getEmptier()
                             throws IOException

Return a Runnable that periodically empties the trash of all users, intended to be run by the superuser.

例外:

IOException

getInstance

public static TrashPolicy getInstance(Configuration conf,
                                      FileSystem fs)
                               throws IOException

Get an instance of the configured TrashPolicy based on the value of the configuration parameter fs.trash.classname.

パラメータ:

conf - the configuration to be used

fs - the file system to be used

戻り値:

an instance of TrashPolicy

例外:

IOException