org.apache.hadoop.hbase.util.compaction

Class MajorCompactionRequest

java.lang.Object

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

@InterfaceAudience.Private
class MajorCompactionRequest
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.conf.Configuration	configuration
private static org.slf4j.Logger	LOG
private RegionInfo	region
private Set<String>	stores
private long	timestamp

Constructor Summary

Constructors

Constructor and Description
MajorCompactionRequest(org.apache.hadoop.conf.Configuration configuration, RegionInfo region, Set<String> stores, long timestamp)

Method Summary

Modifier and Type	Method and Description
(package private) Optional<MajorCompactionRequest>	createRequest(org.apache.hadoop.conf.Configuration configuration, Set<String> stores)
private boolean	familyHasReferenceFile(HRegionFileSystem fileSystem, String family)
(package private) Connection	getConnection(org.apache.hadoop.conf.Configuration configuration)
(package private) HRegionFileSystem	getFileSystem(Connection connection)
(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()
(package private) Set<String>	getStores()
(package private) Set<String>	getStoresRequiringCompaction(Set<String> requestedStores)
(package private) static Optional<MajorCompactionRequest>	newRequest(org.apache.hadoop.conf.Configuration configuration, RegionInfo info, Set<String> stores, long timestamp)
(package private) void	setStores(Set<String> stores)
String	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

configuration

private final org.apache.hadoop.conf.Configuration configuration

region

private final RegionInfo region

stores

private Set<String> stores

timestamp

private final long timestamp

Constructor Detail

MajorCompactionRequest

MajorCompactionRequest(org.apache.hadoop.conf.Configuration configuration,
                       RegionInfo region,
                       Set<String> stores,
                       long timestamp)

Method Detail

newRequest

static Optional<MajorCompactionRequest> newRequest(org.apache.hadoop.conf.Configuration configuration,
                                                   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(org.apache.hadoop.conf.Configuration configuration,
                                               Set<String> stores)
                                        throws IOException

Throws:

IOException

getStoresRequiringCompaction

Set<String> getStoresRequiringCompaction(Set<String> requestedStores)
                                  throws IOException

Throws:

IOException

getConnection

Connection getConnection(org.apache.hadoop.conf.Configuration configuration)
                  throws IOException

Throws:

IOException

familyHasReferenceFile

private boolean familyHasReferenceFile(HRegionFileSystem fileSystem,
                                       String family)
                                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(Connection connection)
                         throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object