@InterfaceAudience.Private public class LogCleaner extends CleanerChore<BaseLogCleanerDelegate>
BaseLogCleanerDelegate
cleanersChain, fs
Constructor and Description |
---|
LogCleaner(int p,
Stoppable s,
Configuration conf,
FileSystem fs,
Path oldLogDir) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
validate(Path file)
Validate the file to see if it even belongs in the directory.
|
chore, cleanup, deleteFiles
cancel, cancel, choreForTesting, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, toString, triggerNow
public LogCleaner(int p, Stoppable s, Configuration conf, FileSystem fs, Path oldLogDir)
p
- the period of time to sleep between each runs
- the stopperconf
- configuration to usefs
- handle to the FSoldLogDir
- the path to the archived logsprotected boolean validate(Path file)
CleanerChore
validate
in class CleanerChore<BaseLogCleanerDelegate>
file
- full Path
of the file to be checked