Package org.apache.hadoop.hbase.util.compaction

Class MajorCompactionRequest

java.lang.Object

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

Direct Known Subclasses:

MajorCompactionTTLRequest

@Private
class MajorCompactionRequest
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final Connection	connection
private static final org.slf4j.Logger	LOG
protected final RegionInfo	region
private Set<String>	stores

Constructor Summary

Constructors

Constructor	Description
MajorCompactionRequest(Connection connection, RegionInfo region)
MajorCompactionRequest(Connection connection, RegionInfo region, Set<String> stores)

Method Summary

Modifier and Type	Method	Description
(package private) Optional<MajorCompactionRequest>	createRequest(Connection connection, Set<String> stores, long timestamp)
protected boolean	familyHasReferenceFile(HRegionFileSystem fileSystem, String family, long ts)
(package private) HRegionFileSystem	getFileSystem()
(package private) List<org.apache.hadoop.fs.Path>	getReferenceFilePaths(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.fs.Path familyDir)
(package private) RegionInfo	getRegion()
StoreFileTracker	getStoreFileTracker(String family, HRegionFileSystem fileSystem)
(package private) Set<String>	getStores()
(package private) Set<String>	getStoresRequiringCompaction(Set<String> requestedStores, long timestamp)
(package private) static Optional<MajorCompactionRequest>	newRequest(Connection connection, RegionInfo info, Set<String> stores, long timestamp)
(package private) void	setStores(Set<String> stores)
(package private) boolean	shouldCFBeCompacted(HRegionFileSystem fileSystem, String family, long ts)
protected boolean	shouldIncludeStore(HRegionFileSystem fileSystem, String family, Collection<StoreFileInfo> storeFiles, long ts)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

connection

protected final Connection connection

region

protected final RegionInfo region

stores

private Set<String> stores

Constructor Details

MajorCompactionRequest

MajorCompactionRequest(Connection connection,
 RegionInfo region)

MajorCompactionRequest

MajorCompactionRequest(Connection connection,
 RegionInfo region,
 Set<String> stores)

Method Details

newRequest

static Optional<MajorCompactionRequest> newRequest(Connection connection,
 RegionInfo info,
 Set<String> stores,
 long timestamp)
                                            throws IOException

Throws:

IOException

getRegion

RegionInfo getRegion()

getStores

Set<String> getStores()

setStores

void setStores(Set<String> stores)

createRequest

Optional<MajorCompactionRequest> createRequest(Connection connection,
 Set<String> stores,
 long timestamp)
                                        throws IOException

Throws:

IOException

getStoresRequiringCompaction

Set<String> getStoresRequiringCompaction(Set<String> requestedStores,
 long timestamp)
                                  throws IOException

Throws:

IOException

shouldCFBeCompacted

boolean shouldCFBeCompacted(HRegionFileSystem fileSystem,
 String family,
 long ts)
                     throws IOException

Throws:

IOException

getStoreFileTracker

public StoreFileTracker getStoreFileTracker(String family,
 HRegionFileSystem fileSystem)
                                     throws IOException

Throws:

IOException

shouldIncludeStore

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

Throws:

IOException

familyHasReferenceFile

protected boolean familyHasReferenceFile(HRegionFileSystem fileSystem,
 String family,
 long ts)
                                  throws IOException

Throws:

IOException

getReferenceFilePaths

List<org.apache.hadoop.fs.Path> getReferenceFilePaths(org.apache.hadoop.fs.FileSystem fileSystem,
 org.apache.hadoop.fs.Path familyDir)
                                               throws IOException

Throws:

IOException

getFileSystem

HRegionFileSystem getFileSystem()
                         throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object