@InterfaceAudience.LimitedPrivate(value="Configuration") public class ReplicationHFileCleaner extends BaseHFileCleanerDelegate
Modifier and Type | Field and Description |
---|---|
private Connection |
conn |
private static org.slf4j.Logger |
LOG |
private ReplicationQueueStorage |
rqs |
private boolean |
shareConn |
private boolean |
stopped |
Constructor and Description |
---|
ReplicationHFileCleaner() |
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
|
boolean |
isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
Should the master delete the file or keep it?
|
boolean |
isStopped()
Returns True if
Stoppable.stop(String) has been closed. |
void |
stop(String why)
Stop this service.
|
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isEmptyDirDeletable, postClean, preClean
private static final org.slf4j.Logger LOG
private Connection conn
private boolean shareConn
private ReplicationQueueStorage rqs
private boolean stopped
public ReplicationHFileCleaner()
public Iterable<org.apache.hadoop.fs.FileStatus> getDeletableFiles(Iterable<org.apache.hadoop.fs.FileStatus> files)
FileCleanerDelegate
getDeletableFiles
in interface FileCleanerDelegate
getDeletableFiles
in class BaseFileCleanerDelegate
files
- files to check for deletionpublic void init(Map<String,Object> params)
FileCleanerDelegate
init
in interface FileCleanerDelegate
init
in class BaseFileCleanerDelegate
public void stop(String why)
Stoppable
stop
in interface Stoppable
stop
in class BaseHFileCleanerDelegate
why
- Why we're stopping.public boolean isStopped()
Stoppable
Stoppable.stop(String)
has been closed.isStopped
in interface Stoppable
isStopped
in class BaseHFileCleanerDelegate
public boolean isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
BaseFileCleanerDelegate
isFileDeletable
in class BaseFileCleanerDelegate
fStat
- file status of the file to checkCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.