org.apache.hadoop.hbase.util.compaction

Class MajorCompactionTTLRequest

java.lang.Object

org.apache.hadoop.hbase.util.compaction.MajorCompactionRequest

org.apache.hadoop.hbase.util.compaction.MajorCompactionTTLRequest

@InterfaceAudience.Private
public class MajorCompactionTTLRequest
extends MajorCompactionRequest

This request helps determine if a region has to be compacted based on table's TTL.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.util.compaction.MajorCompactionRequest

configuration, region

Constructor Summary

Constructors

Constructor and Description
MajorCompactionTTLRequest(org.apache.hadoop.conf.Configuration conf, RegionInfo region)

Method Summary

Modifier and Type	Method and Description
private Optional<MajorCompactionRequest>	createRequest(org.apache.hadoop.conf.Configuration conf, TableDescriptor htd)
private long	getColFamilyCutoffTime(ColumnFamilyDescriptor colDesc)
(package private) Map<String,Long>	getStoresRequiringCompaction(TableDescriptor htd)
(package private) static Optional<MajorCompactionRequest>	newRequest(org.apache.hadoop.conf.Configuration conf, RegionInfo info, TableDescriptor htd)
protected boolean	shouldIncludeStore(HRegionFileSystem fileSystem, String family, Collection<StoreFileInfo> storeFiles, long ts)

Methods inherited from class org.apache.hadoop.hbase.util.compaction.MajorCompactionRequest

createRequest, familyHasReferenceFile, getConnection, getFileSystem, getReferenceFilePaths, getRegion, getStores, getStoresRequiringCompaction, newRequest, setStores, shouldCFBeCompacted, toString

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

MajorCompactionTTLRequest

MajorCompactionTTLRequest(org.apache.hadoop.conf.Configuration conf,
                          RegionInfo region)

Method Detail

newRequest

static Optional<MajorCompactionRequest> newRequest(org.apache.hadoop.conf.Configuration conf,
                                                   RegionInfo info,
                                                   TableDescriptor htd)
                                            throws IOException

Throws:

IOException

createRequest

private Optional<MajorCompactionRequest> createRequest(org.apache.hadoop.conf.Configuration conf,
                                                       TableDescriptor htd)
                                                throws IOException

Throws:

IOException

getStoresRequiringCompaction

Map<String,Long> getStoresRequiringCompaction(TableDescriptor htd)
                                       throws IOException

Throws:

IOException

getColFamilyCutoffTime

private long getColFamilyCutoffTime(ColumnFamilyDescriptor colDesc)

shouldIncludeStore

protected boolean shouldIncludeStore(HRegionFileSystem fileSystem,
                                     String family,
                                     Collection<StoreFileInfo> storeFiles,
                                     long ts)
                              throws IOException

Overrides:

shouldIncludeStore in class MajorCompactionRequest

Throws:

IOException