@InterfaceAudience.Private public class CompactedHFilesDischarger extends ScheduledChore
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private RegionServerServices |
regionServerServices |
private boolean |
useExecutor |
Constructor and Description |
---|
CompactedHFilesDischarger(int period,
Stoppable stopper,
RegionServerServices regionServerServices) |
CompactedHFilesDischarger(int period,
Stoppable stopper,
RegionServerServices regionServerServices,
boolean useExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
chore()
The task to execute on each scheduled execution of the Chore
|
(package private) boolean |
setUseExecutor(boolean useExecutor)
CompactedHFilesDischarger runs asynchronously by default using the hosting RegionServer's
Executor.
|
cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, shutdown, shutdown, toString, triggerNow
private static final org.slf4j.Logger LOG
private RegionServerServices regionServerServices
private boolean useExecutor
public CompactedHFilesDischarger(int period, Stoppable stopper, RegionServerServices regionServerServices)
period
- the period of time to sleep between each runstopper
- the stopperregionServerServices
- the region server that starts this chorepublic CompactedHFilesDischarger(int period, Stoppable stopper, RegionServerServices regionServerServices, boolean useExecutor)
period
- the period of time to sleep between each runstopper
- the stopperregionServerServices
- the region server that starts this choreuseExecutor
- true if to use the region server's executor service, false
otherwiseboolean setUseExecutor(boolean useExecutor)
useExecutor
public void chore()
ScheduledChore
chore
in class ScheduledChore
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.