public abstract class MobCompactor
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyDescriptor |
column |
protected Configuration |
conf |
protected FileSystem |
fs |
protected Path |
mobFamilyDir |
protected Path |
mobTableDir |
protected java.util.concurrent.ExecutorService |
pool |
protected TableName |
tableName |
Constructor and Description |
---|
MobCompactor(Configuration conf,
FileSystem fs,
TableName tableName,
ColumnFamilyDescriptor column,
java.util.concurrent.ExecutorService pool) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Path> |
compact()
Compacts the mob files for the current column family.
|
java.util.List<Path> |
compact(boolean allFiles)
Compacts the mob files by compaction type for the current column family.
|
abstract java.util.List<Path> |
compact(java.util.List<FileStatus> files,
boolean allFiles)
Compacts the candidate mob files.
|
protected FileSystem fs
protected Configuration conf
protected TableName tableName
protected ColumnFamilyDescriptor column
protected Path mobTableDir
protected Path mobFamilyDir
protected java.util.concurrent.ExecutorService pool
public MobCompactor(Configuration conf, FileSystem fs, TableName tableName, ColumnFamilyDescriptor column, java.util.concurrent.ExecutorService pool)
public java.util.List<Path> compact() throws java.io.IOException
java.io.IOException
public java.util.List<Path> compact(boolean allFiles) throws java.io.IOException
allFiles
- Whether add all mob files into the compaction.java.io.IOException
public abstract java.util.List<Path> compact(java.util.List<FileStatus> files, boolean allFiles) throws java.io.IOException
files
- The candidate mob files.allFiles
- Whether add all mob files into the compaction.java.io.IOException