public abstract class BaseFileCleanerDelegate extends BaseConfigurable implements FileCleanerDelegate
Constructor and Description |
---|
BaseFileCleanerDelegate() |
Modifier and Type | Method and Description |
---|---|
Iterable<org.apache.hadoop.fs.FileStatus> |
getDeletableFiles(Iterable<org.apache.hadoop.fs.FileStatus> files)
Determines which of the given files are safe to delete
|
void |
init(Map<String,Object> params)
this method is used to pass some instance into subclass
|
protected abstract boolean |
isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
Should the master delete the file or keep it?
|
getConf, setConf
public Iterable<org.apache.hadoop.fs.FileStatus> getDeletableFiles(Iterable<org.apache.hadoop.fs.FileStatus> files)
FileCleanerDelegate
getDeletableFiles
in interface FileCleanerDelegate
files
- files to check for deletionpublic void init(Map<String,Object> params)
FileCleanerDelegate
init
in interface FileCleanerDelegate
protected abstract boolean isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
fStat
- file status of the file to checkCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.