T
- Cleaner delegate class that is dynamically loaded from configurationpublic abstract class CleanerChore<T extends FileCleanerDelegate> extends ScheduledChore implements ConfigurationObserver
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CHORE_POOL_SIZE
If it is an integer and >= 1, it would be the size;
if 0.0 < size <= 1.0, size would be available processors * size.
|
protected java.util.List<T> |
cleanersChain |
protected FileSystem |
fs |
protected java.util.Map<java.lang.String,java.lang.Object> |
params |
Constructor and Description |
---|
CleanerChore(java.lang.String name,
int sleepPeriod,
Stoppable s,
Configuration conf,
FileSystem fs,
Path oldFileDir,
java.lang.String confKey) |
CleanerChore(java.lang.String name,
int sleepPeriod,
Stoppable s,
Configuration conf,
FileSystem fs,
Path oldFileDir,
java.lang.String confKey,
java.util.Map<java.lang.String,java.lang.Object> params) |
Modifier and Type | Method and Description |
---|---|
protected void |
chore() |
void |
cleanup() |
protected int |
deleteFiles(java.lang.Iterable<FileStatus> filesToDelete)
Delete the given files
|
boolean |
getEnabled() |
void |
onConfigurationChange(Configuration conf)
This method would be called by the
ConfigurationManager
object when the Configuration object is reloaded from disk. |
java.lang.Boolean |
runCleaner() |
boolean |
setEnabled(boolean enabled) |
protected abstract boolean |
validate(Path file)
Validate the file to see if it even belongs in the directory.
|
public static final java.lang.String CHORE_POOL_SIZE
protected final FileSystem fs
protected final java.util.Map<java.lang.String,java.lang.Object> params
protected java.util.List<T extends FileCleanerDelegate> cleanersChain
public CleanerChore(java.lang.String name, int sleepPeriod, Stoppable s, Configuration conf, FileSystem fs, Path oldFileDir, java.lang.String confKey)
public CleanerChore(java.lang.String name, int sleepPeriod, Stoppable s, Configuration conf, FileSystem fs, Path oldFileDir, java.lang.String confKey, java.util.Map<java.lang.String,java.lang.Object> params)
name
- name of the chore being runsleepPeriod
- the period of time to sleep between each runs
- the stopperconf
- configuration to usefs
- handle to the FSoldFileDir
- the path to the archived filesconfKey
- configuration key for the classes to instantiateparams
- members could be used in cleanerprotected abstract boolean validate(Path file)
file
- full Path
of the file to be checkedpublic void onConfigurationChange(Configuration conf)
ConfigurationObserver
ConfigurationManager
object when the Configuration
object is reloaded from disk.onConfigurationChange
in interface ConfigurationObserver
protected void chore()
public java.lang.Boolean runCleaner()
protected int deleteFiles(java.lang.Iterable<FileStatus> filesToDelete)
filesToDelete
- files to deletepublic void cleanup()
public boolean setEnabled(boolean enabled)
enabled
- public boolean getEnabled()