org.apache.hadoop.hbase.util.compaction

Class MajorCompactor

java.lang.Object

org.apache.hadoop.hbase.util.compaction.MajorCompactor

@InterfaceAudience.LimitedPrivate(value="Tools")
public class MajorCompactor
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	MajorCompactor.Compact

Field Summary

Fields

Modifier and Type	Field and Description
private ClusterCompactionQueues	clusterCompactionQueues
private Connection	connection
private static Set<MajorCompactionRequest>	ERRORS
private ExecutorService	executor
private static org.slf4j.Logger	LOG
private long	sleepForMs
private Set<String>	storesToCompact
private TableName	tableName
private long	timestamp

Constructor Summary

Constructors

Constructor and Description
MajorCompactor(org.apache.hadoop.conf.Configuration conf, TableName tableName, Set<String> storesToCompact, int concurrency, long timestamp, long sleepForMs)

Method Summary

Modifier and Type	Method and Description
private void	addNewRegions()
void	compactAllRegions()
private boolean	futuresComplete(List<Future<?>> futures)
(package private) void	initializeWorkQueues()
private boolean	isCompacting(MajorCompactionRequest request)
static void	main(String[] args)
private static void	printUsage(org.apache.hbase.thirdparty.org.apache.commons.cli.Options options)
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

ERRORS

private static final Set<MajorCompactionRequest> ERRORS

clusterCompactionQueues

private final ClusterCompactionQueues clusterCompactionQueues

timestamp

private final long timestamp

storesToCompact

private final Set<String> storesToCompact

executor

private final ExecutorService executor

sleepForMs

private final long sleepForMs

connection

private final Connection connection

tableName

private final TableName tableName

Constructor Detail

MajorCompactor

public MajorCompactor(org.apache.hadoop.conf.Configuration conf,
                      TableName tableName,
                      Set<String> storesToCompact,
                      int concurrency,
                      long timestamp,
                      long sleepForMs)
               throws IOException

Throws:

IOException

Method Detail

compactAllRegions

public void compactAllRegions()
                       throws Exception

Throws:

Exception

futuresComplete

private boolean futuresComplete(List<Future<?>> futures)

shutdown

public void shutdown()
              throws Exception

Throws:

Exception

initializeWorkQueues

void initializeWorkQueues()
                   throws IOException

Throws:

IOException

isCompacting

private boolean isCompacting(MajorCompactionRequest request)
                      throws Exception

Throws:

Exception

addNewRegions

private void addNewRegions()

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

printUsage

private static void printUsage(org.apache.hbase.thirdparty.org.apache.commons.cli.Options options)