org.apache.hadoop.hbase.mob.filecompactions

Class MobFileCompactor

java.lang.Object

org.apache.hadoop.hbase.mob.filecompactions.MobFileCompactor

Direct Known Subclasses:

PartitionedMobFileCompactor

@InterfaceAudience.Private
public abstract class MobFileCompactor
extends Object

A mob file compactor to directly compact the mob files.

Field Summary

Fields

Modifier and Type	Field and Description
protected HColumnDescriptor	column
protected org.apache.hadoop.conf.Configuration	conf
protected org.apache.hadoop.fs.FileSystem	fs
protected org.apache.hadoop.fs.Path	mobFamilyDir
protected org.apache.hadoop.fs.Path	mobTableDir
protected ExecutorService	pool
protected TableName	tableName

Constructor Summary

Constructors

Constructor and Description
MobFileCompactor(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, TableName tableName, HColumnDescriptor column, ExecutorService pool)

Method Summary

Methods

Modifier and Type	Method and Description
List<org.apache.hadoop.fs.Path>	compact() Compacts the mob files for the current column family.
List<org.apache.hadoop.fs.Path>	compact(boolean isForceAllFiles) Compacts the mob files by compaction type for the current column family.
abstract List<org.apache.hadoop.fs.Path>	compact(List<org.apache.hadoop.fs.FileStatus> files, boolean isForceAllFiles) Compacts the candidate mob files.

Methods inherited from class java.lang.Object

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

Field Detail

fs

protected org.apache.hadoop.fs.FileSystem fs

conf

protected org.apache.hadoop.conf.Configuration conf

tableName

protected TableName tableName

column

protected HColumnDescriptor column

mobTableDir

protected org.apache.hadoop.fs.Path mobTableDir

mobFamilyDir

protected org.apache.hadoop.fs.Path mobFamilyDir

pool

protected ExecutorService pool

Constructor Detail

MobFileCompactor

public MobFileCompactor(org.apache.hadoop.conf.Configuration conf,
                org.apache.hadoop.fs.FileSystem fs,
                TableName tableName,
                HColumnDescriptor column,
                ExecutorService pool)

Method Detail

compact

public List<org.apache.hadoop.fs.Path> compact()
                                        throws IOException

Compacts the mob files for the current column family.

Returns:

The paths of new mob files generated in the compaction.

Throws:

IOException

compact

public List<org.apache.hadoop.fs.Path> compact(boolean isForceAllFiles)
                                        throws IOException

Compacts the mob files by compaction type for the current column family.

Parameters:

isForceAllFiles - Whether add all mob files into the compaction.

Returns:

The paths of new mob files generated in the compaction.

Throws:

IOException

compact

public abstract List<org.apache.hadoop.fs.Path> compact(List<org.apache.hadoop.fs.FileStatus> files,
                                      boolean isForceAllFiles)
                                                 throws IOException

Compacts the candidate mob files.

Parameters:

files - The candidate mob files.

isForceAllFiles - Whether add all mob files into the compaction.

Returns:

The paths of new mob files generated in the compaction.

Throws:

IOException