org.apache.hadoop.hbase.mob.compactions

Class TestPartitionedMobCompactor.MyPartitionedMobCompactor

java.lang.Object

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

org.apache.hadoop.hbase.mob.compactions.PartitionedMobCompactor

org.apache.hadoop.hbase.mob.compactions.TestPartitionedMobCompactor.MyPartitionedMobCompactor

Enclosing class:

TestPartitionedMobCompactor

static class TestPartitionedMobCompactor.MyPartitionedMobCompactor
extends org.apache.hadoop.hbase.mob.compactions.PartitionedMobCompactor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.mob.compactions.PartitionedMobCompactor

org.apache.hadoop.hbase.mob.compactions.PartitionedMobCompactor.DelPartitionComparator

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.hadoop.hbase.io.hfile.CacheConfig	cacheConfig
(package private) int	delPartitionSize
(package private) int	PartitionsIncludeDelFiles

Fields inherited from class org.apache.hadoop.hbase.mob.compactions.PartitionedMobCompactor

compactionBatchSize, compactionKVMax, delFileMaxCount, mergeableSize

Fields inherited from class org.apache.hadoop.hbase.mob.compactions.MobCompactor

column, conf, fs, mobFamilyDir, mobTableDir, pool, tableName

Constructor Summary

Constructors

Constructor and Description
MyPartitionedMobCompactor(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor column, ExecutorService pool, int delPartitionSize, org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf, int PartitionsIncludeDelFiles)

Method Summary

Modifier and Type	Method and Description
List<org.apache.hadoop.fs.Path>	compact(List<org.apache.hadoop.fs.FileStatus> files, boolean isForceAllFiles)

Methods inherited from class org.apache.hadoop.hbase.mob.compactions.PartitionedMobCompactor

compactDelFiles, compactMobFiles, getListOfDelFilesForPartition, performCompaction, select

Methods inherited from class org.apache.hadoop.hbase.mob.compactions.MobCompactor

compact, compact

Methods inherited from class java.lang.Object

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

Field Detail

delPartitionSize

int delPartitionSize

PartitionsIncludeDelFiles

int PartitionsIncludeDelFiles

cacheConfig

org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConfig

Constructor Detail

MyPartitionedMobCompactor

MyPartitionedMobCompactor(org.apache.hadoop.conf.Configuration conf,
                          org.apache.hadoop.fs.FileSystem fs,
                          org.apache.hadoop.hbase.TableName tableName,
                          org.apache.hadoop.hbase.client.ColumnFamilyDescriptor column,
                          ExecutorService pool,
                          int delPartitionSize,
                          org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf,
                          int PartitionsIncludeDelFiles)
                   throws IOException

Throws:

IOException

Method Detail

compact

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

Overrides:

compact in class org.apache.hadoop.hbase.mob.compactions.PartitionedMobCompactor

Throws:

IOException