@InterfaceAudience.Private public class HFileCleaner extends CleanerChore<BaseHFileCleanerDelegate>
Modifier and Type | Field and Description |
---|---|
static String |
MASTER_HFILE_CLEANER_PLUGINS |
cleanersChain
Constructor and Description |
---|
HFileCleaner(int period,
Stoppable stopper,
Configuration conf,
FileSystem fs,
Path directory) |
Modifier and Type | Method and Description |
---|---|
List<BaseHFileCleanerDelegate> |
getDelegatesForTesting()
Exposed for TESTING!
|
protected boolean |
validate(Path file)
Validate the file to see if it even belongs in the directory.
|
chore, cleanup
cancel, cancel, choreForTesting, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, toString, triggerNow
public static final String MASTER_HFILE_CLEANER_PLUGINS
public HFileCleaner(int period, Stoppable stopper, Configuration conf, FileSystem fs, Path directory)
period
- the period of time to sleep between each runstopper
- the stopperconf
- configuration to usefs
- handle to the FSdirectory
- directory to be cleanedprotected boolean validate(Path file)
CleanerChore
validate
in class CleanerChore<BaseHFileCleanerDelegate>
file
- full Path
of the file to be checkedpublic List<BaseHFileCleanerDelegate> getDelegatesForTesting()