@InterfaceAudience.Private class MajorCompactionRequest extends Object
Modifier and Type | Field and Description |
---|---|
protected Connection |
connection |
private static org.slf4j.Logger |
LOG |
protected RegionInfo |
region |
private Set<String> |
stores |
Constructor and Description |
---|
MajorCompactionRequest(Connection connection,
RegionInfo region) |
MajorCompactionRequest(Connection connection,
RegionInfo region,
Set<String> stores) |
Modifier and Type | Method and 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() |
(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() |
private static final org.slf4j.Logger LOG
protected final Connection connection
protected final RegionInfo region
MajorCompactionRequest(Connection connection, RegionInfo region)
MajorCompactionRequest(Connection connection, RegionInfo region, Set<String> stores)
static Optional<MajorCompactionRequest> newRequest(Connection connection, RegionInfo info, Set<String> stores, long timestamp) throws IOException
IOException
RegionInfo getRegion()
Optional<MajorCompactionRequest> createRequest(Connection connection, Set<String> stores, long timestamp) throws IOException
IOException
Set<String> getStoresRequiringCompaction(Set<String> requestedStores, long timestamp) throws IOException
IOException
boolean shouldCFBeCompacted(HRegionFileSystem fileSystem, String family, long ts) throws IOException
IOException
protected boolean shouldIncludeStore(HRegionFileSystem fileSystem, String family, Collection<StoreFileInfo> storeFiles, long ts) throws IOException
IOException
protected boolean familyHasReferenceFile(HRegionFileSystem fileSystem, String family, long ts) throws IOException
IOException
List<org.apache.hadoop.fs.Path> getReferenceFilePaths(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.fs.Path familyDir) throws IOException
IOException
HRegionFileSystem getFileSystem() throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.