org.apache.hadoop.hbase.regionserver

Class CompactionTool

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.regionserver.CompactionTool

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

@InterfaceAudience.LimitedPrivate(value="Tools")
public class CompactionTool
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	CompactionTool.CompactionInputFormat Input format that uses store files block location as input split locality.
private static class	CompactionTool.CompactionMapper
private static class	CompactionTool.CompactionWorker Class responsible to execute the Compaction on the specified path.

Field Summary

Fields

Modifier and Type	Field and Description
private static String	CONF_COMPACT_MAJOR
private static String	CONF_COMPACT_ONCE
private static String	CONF_DELETE_COMPACTED
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
CompactionTool()

Method Summary

Modifier and Type	Method and Description
private int	doClient(org.apache.hadoop.fs.FileSystem fs, Set<org.apache.hadoop.fs.Path> toCompactDirs, boolean compactOnce, boolean major) Execute compaction, from this client, one path at the time.
private int	doMapReduce(org.apache.hadoop.fs.FileSystem fs, Set<org.apache.hadoop.fs.Path> toCompactDirs, boolean compactOnce, boolean major) Execute compaction, using a Map-Reduce job.
private static boolean	isFamilyDir(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)
private static boolean	isRegionDir(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)
private static boolean	isTableDir(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)
static void	main(String[] args)
private void	printUsage()
private void	printUsage(String message)
int	run(String[] args)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Detail

LOG

private static final org.slf4j.Logger LOG

CONF_COMPACT_ONCE

private static final String CONF_COMPACT_ONCE

See Also:

Constant Field Values

CONF_COMPACT_MAJOR

private static final String CONF_COMPACT_MAJOR

See Also:

Constant Field Values

CONF_DELETE_COMPACTED

private static final String CONF_DELETE_COMPACTED

See Also:

Constant Field Values

Constructor Detail

CompactionTool

public CompactionTool()

Method Detail

isRegionDir

private static boolean isRegionDir(org.apache.hadoop.fs.FileSystem fs,
                                   org.apache.hadoop.fs.Path path)
                            throws IOException

Throws:

IOException

isTableDir

private static boolean isTableDir(org.apache.hadoop.fs.FileSystem fs,
                                  org.apache.hadoop.fs.Path path)
                           throws IOException

Throws:

IOException

isFamilyDir

private static boolean isFamilyDir(org.apache.hadoop.fs.FileSystem fs,
                                   org.apache.hadoop.fs.Path path)
                            throws IOException

Throws:

IOException

doMapReduce

private int doMapReduce(org.apache.hadoop.fs.FileSystem fs,
                        Set<org.apache.hadoop.fs.Path> toCompactDirs,
                        boolean compactOnce,
                        boolean major)
                 throws Exception

Execute compaction, using a Map-Reduce job.

Throws:

Exception

doClient

private int doClient(org.apache.hadoop.fs.FileSystem fs,
                     Set<org.apache.hadoop.fs.Path> toCompactDirs,
                     boolean compactOnce,
                     boolean major)
              throws IOException

Execute compaction, from this client, one path at the time.

Throws:

IOException

run

public int run(String[] args)
        throws Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Throws:

Exception

printUsage

private void printUsage()

printUsage

private void printUsage(String message)

main

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

Throws:

Exception