org.apache.hadoop.hbase.regionserver

Class CompactionTool.CompactionWorker

java.lang.Object

org.apache.hadoop.hbase.regionserver.CompactionTool.CompactionWorker

Enclosing class:

CompactionTool

private static class CompactionTool.CompactionWorker
extends Object

Class responsible to execute the Compaction on the specified path. The path can be a table, region or family directory.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.conf.Configuration	conf
private boolean	deleteCompacted
private org.apache.hadoop.fs.FileSystem	fs
private org.apache.hadoop.fs.Path	tmpDir

Constructor Summary

Constructors

Constructor and Description
CompactionWorker(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	compact(org.apache.hadoop.fs.Path path, boolean compactOnce, boolean major) Execute the compaction on the specified path.
private void	compactRegion(org.apache.hadoop.fs.Path tableDir, TableDescriptor htd, org.apache.hadoop.fs.Path regionDir, boolean compactOnce, boolean major)
private void	compactStoreFiles(org.apache.hadoop.fs.Path tableDir, TableDescriptor htd, RegionInfo hri, String familyName, boolean compactOnce, boolean major) Execute the actual compaction job.
private void	compactTable(org.apache.hadoop.fs.Path tableDir, boolean compactOnce, boolean major)
private static HStore	getStore(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path tableDir, TableDescriptor htd, RegionInfo hri, String familyName, org.apache.hadoop.fs.Path tempDir) Create a "mock" HStore that uses the tmpDir specified by the user and the store dir to compact as source.

Methods inherited from class java.lang.Object

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

Field Detail

deleteCompacted

private final boolean deleteCompacted

conf

private final org.apache.hadoop.conf.Configuration conf

fs

private final org.apache.hadoop.fs.FileSystem fs

tmpDir

private final org.apache.hadoop.fs.Path tmpDir

Constructor Detail

CompactionWorker

public CompactionWorker(org.apache.hadoop.fs.FileSystem fs,
                        org.apache.hadoop.conf.Configuration conf)

Method Detail

compact

public void compact(org.apache.hadoop.fs.Path path,
                    boolean compactOnce,
                    boolean major)
             throws IOException

Execute the compaction on the specified path.

Parameters:

path - Directory path on which to run compaction.

compactOnce - Execute just a single step of compaction.

major - Request major compaction.

Throws:

IOException

compactTable

private void compactTable(org.apache.hadoop.fs.Path tableDir,
                          boolean compactOnce,
                          boolean major)
                   throws IOException

Throws:

IOException

compactRegion

private void compactRegion(org.apache.hadoop.fs.Path tableDir,
                           TableDescriptor htd,
                           org.apache.hadoop.fs.Path regionDir,
                           boolean compactOnce,
                           boolean major)
                    throws IOException

Throws:

IOException

compactStoreFiles

private void compactStoreFiles(org.apache.hadoop.fs.Path tableDir,
                               TableDescriptor htd,
                               RegionInfo hri,
                               String familyName,
                               boolean compactOnce,
                               boolean major)
                        throws IOException

Execute the actual compaction job. If the compact once flag is not specified, execute the compaction until no more compactions are needed. Uses the Configuration settings provided.

Throws:

IOException

getStore

private static HStore getStore(org.apache.hadoop.conf.Configuration conf,
                               org.apache.hadoop.fs.FileSystem fs,
                               org.apache.hadoop.fs.Path tableDir,
                               TableDescriptor htd,
                               RegionInfo hri,
                               String familyName,
                               org.apache.hadoop.fs.Path tempDir)
                        throws IOException

Create a "mock" HStore that uses the tmpDir specified by the user and the store dir to compact as source.

Throws:

IOException