org.apache.hadoop.hbase.mob.compactions

Class MobCompactor

java.lang.Object

org.apache.hadoop.hbase.mob.compactions.MobCompactor

Direct Known Subclasses:

PartitionedMobCompactor

@InterfaceAudience.Private
public abstract class MobCompactor
extends Object

A mob compactor to directly compact the mob files.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
MobCompactor(Configuration conf, FileSystem fs, TableName tableName, HColumnDescriptor column, ExecutorService pool)

Method Summary

Modifier and Type	Method and Description
List<Path>	compact() Compacts the mob files for the current column family.
List<Path>	compact(boolean allFiles) Compacts the mob files by compaction type for the current column family.
abstract List<Path>	compact(List<FileStatus> files, boolean allFiles) 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 FileSystem fs

conf

protected Configuration conf

tableName

protected TableName tableName

column

protected HColumnDescriptor column

mobTableDir

protected Path mobTableDir

mobFamilyDir

protected Path mobFamilyDir

pool

protected ExecutorService pool

Constructor Detail

MobCompactor

public MobCompactor(Configuration conf,
                    FileSystem fs,
                    TableName tableName,
                    HColumnDescriptor column,
                    ExecutorService pool)

Method Detail

compact

public List<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<Path> compact(boolean allFiles)
                   throws IOException

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

Parameters:

allFiles - 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<Path> compact(List<FileStatus> files,
                                   boolean allFiles)
                            throws IOException

Compacts the candidate mob files.

Parameters:

files - The candidate mob files.

allFiles - Whether add all mob files into the compaction.

Returns:

The paths of new mob files generated in the compaction.

Throws:

IOException