Field Detail

• keepCompactedFiles

  private final boolean keepCompactedFiles

• 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

• CompactionTool.CompactionWorker

  public CompactionTool.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,
                   HTableDescriptor 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,
                       HTableDescriptor htd,
                       HRegionInfo 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,
                HTableDescriptor htd,
                HRegionInfo 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