@InterfaceAudience.LimitedPrivate(value="Tools") public class MajorCompactorTTL extends MajorCompactor
MajorCompactor.Compact
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
htd |
private static org.slf4j.Logger |
LOG |
clusterCompactionQueues, connection, ERRORS, executor, sleepForMs, storesToCompact, tableName
Modifier | Constructor and Description |
---|---|
protected |
MajorCompactorTTL() |
|
MajorCompactorTTL(org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd,
int concurrency,
long sleepForMs) |
Modifier and Type | Method and Description |
---|---|
int |
compactRegionsTTLOnTable(org.apache.hadoop.conf.Configuration conf,
String table,
int concurrency,
long sleep,
int numServers,
int numRegions,
boolean dryRun,
boolean skipWait) |
private boolean |
doesAnyColFamilyHaveTTL(TableDescriptor htd) |
protected Optional<MajorCompactionRequest> |
getMajorCompactionRequest(RegionInfo hri) |
private org.apache.hbase.thirdparty.org.apache.commons.cli.Options |
getOptions() |
protected Set<String> |
getStoresRequiringCompaction(MajorCompactionRequest request) |
static void |
main(String[] args) |
int |
run(String[] args) |
compactAllRegions, getCommonOptions, initializeWorkQueues, printUsage, setNumRegions, setNumServers, setSkipWait, shutdown
private static final org.slf4j.Logger LOG
private TableDescriptor htd
@InterfaceAudience.Private public MajorCompactorTTL(org.apache.hadoop.conf.Configuration conf, TableDescriptor htd, int concurrency, long sleepForMs) throws IOException
IOException
protected MajorCompactorTTL()
protected Optional<MajorCompactionRequest> getMajorCompactionRequest(RegionInfo hri) throws IOException
getMajorCompactionRequest
in class MajorCompactor
IOException
protected Set<String> getStoresRequiringCompaction(MajorCompactionRequest request) throws IOException
getStoresRequiringCompaction
in class MajorCompactor
IOException
public int compactRegionsTTLOnTable(org.apache.hadoop.conf.Configuration conf, String table, int concurrency, long sleep, int numServers, int numRegions, boolean dryRun, boolean skipWait) throws Exception
Exception
private boolean doesAnyColFamilyHaveTTL(TableDescriptor htd)
private org.apache.hbase.thirdparty.org.apache.commons.cli.Options getOptions()
public int run(String[] args) throws Exception
run
in interface org.apache.hadoop.util.Tool
run
in class MajorCompactor
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.