public class StripeStoreFileManager extends java.lang.Object implements StripeCompactionPolicy.StripeInformationProvider
Modifier and Type | Field and Description |
---|---|
static byte[] |
OPEN_KEY
The key value used for range boundary, indicating that the boundary is open (i.e.
|
static byte[] |
STRIPE_END_KEY |
static byte[] |
STRIPE_START_KEY
The file metadata fields that contain the stripe information.
|
Constructor and Description |
---|
StripeStoreFileManager(CellComparator kvComparator,
Configuration conf,
StripeStoreConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
addCompactionResults(java.util.Collection<HStoreFile> compactedFiles,
java.util.Collection<HStoreFile> results) |
<any> |
clearCompactedFiles() |
<any> |
clearFiles() |
java.util.Iterator<HStoreFile> |
getCandidateFilesForRowKeyBefore(KeyValue targetKey)
See
StoreFileManager#getCandidateFilesForRowKeyBefore(KeyValue)
for details on this methods. |
java.util.Collection<HStoreFile> |
getCompactedfiles() |
int |
getCompactedFilesCount() |
double |
getCompactionPressure() |
byte[] |
getEndRow(int stripeIndex)
Gets the end row for a given stripe.
|
java.util.Collection<HStoreFile> |
getFilesForScan(byte[] startRow,
boolean includeStartRow,
byte[] stopRow,
boolean includeStopRow) |
java.util.List<HStoreFile> |
getLevel0Files() |
java.util.Optional<byte[]> |
getSplitPoint()
Override of getSplitPoint that determines the split point as the boundary between two
stripes, unless it causes significant imbalance between split sides' sizes.
|
byte[] |
getStartRow(int stripeIndex)
Gets the start row for a given stripe.
|
int |
getStoreCompactionPriority() |
java.util.Comparator<HStoreFile> |
getStoreFileComparator() |
int |
getStorefileCount() |
java.util.Collection<HStoreFile> |
getStorefiles() |
java.util.List<byte[]> |
getStripeBoundaries() |
int |
getStripeCount() |
java.util.ArrayList<<any>> |
getStripes() |
java.util.Collection<HStoreFile> |
getUnneededFiles(long maxTs,
java.util.List<HStoreFile> filesCompacting) |
void |
insertNewFiles(java.util.Collection<HStoreFile> sfs) |
void |
loadFiles(java.util.List<HStoreFile> storeFiles) |
void |
removeCompactedFiles(java.util.Collection<HStoreFile> compactedFiles) |
java.util.Iterator<HStoreFile> |
updateCandidateFilesForRowKeyBefore(java.util.Iterator<HStoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
See
StoreFileManager#getCandidateFilesForRowKeyBefore(KeyValue) and
StoreFileManager#updateCandidateFilesForRowKeyBefore(Iterator, KeyValue, Cell)
for details on this methods. |
public static final byte[] STRIPE_START_KEY
public static final byte[] STRIPE_END_KEY
public static final byte[] OPEN_KEY
public StripeStoreFileManager(CellComparator kvComparator, Configuration conf, StripeStoreConfig config)
public void loadFiles(java.util.List<HStoreFile> storeFiles)
public java.util.Collection<HStoreFile> getStorefiles()
getStorefiles
in interface StripeCompactionPolicy.StripeInformationProvider
public java.util.Collection<HStoreFile> getCompactedfiles()
public int getCompactedFilesCount()
public void insertNewFiles(java.util.Collection<HStoreFile> sfs) throws java.io.IOException
java.io.IOException
public <any> clearFiles()
public <any> clearCompactedFiles()
public int getStorefileCount()
public java.util.Iterator<HStoreFile> getCandidateFilesForRowKeyBefore(KeyValue targetKey)
StoreFileManager#getCandidateFilesForRowKeyBefore(KeyValue)
for details on this methods.public java.util.Iterator<HStoreFile> updateCandidateFilesForRowKeyBefore(java.util.Iterator<HStoreFile> candidateFiles, KeyValue targetKey, Cell candidate)
StoreFileManager#getCandidateFilesForRowKeyBefore(KeyValue)
and
StoreFileManager#updateCandidateFilesForRowKeyBefore(Iterator, KeyValue, Cell)
for details on this methods.public java.util.Optional<byte[]> getSplitPoint() throws java.io.IOException
java.io.IOException
public java.util.Collection<HStoreFile> getFilesForScan(byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow)
public void addCompactionResults(java.util.Collection<HStoreFile> compactedFiles, java.util.Collection<HStoreFile> results) throws java.io.IOException
java.io.IOException
public void removeCompactedFiles(java.util.Collection<HStoreFile> compactedFiles) throws java.io.IOException
java.io.IOException
public int getStoreCompactionPriority()
public final byte[] getStartRow(int stripeIndex)
StripeCompactionPolicy.StripeInformationProvider
getStartRow
in interface StripeCompactionPolicy.StripeInformationProvider
stripeIndex
- Stripe index.public final byte[] getEndRow(int stripeIndex)
StripeCompactionPolicy.StripeInformationProvider
getEndRow
in interface StripeCompactionPolicy.StripeInformationProvider
stripeIndex
- Stripe index.public java.util.List<HStoreFile> getLevel0Files()
getLevel0Files
in interface StripeCompactionPolicy.StripeInformationProvider
public java.util.List<byte[]> getStripeBoundaries()
getStripeBoundaries
in interface StripeCompactionPolicy.StripeInformationProvider
public java.util.ArrayList<<any>> getStripes()
getStripes
in interface StripeCompactionPolicy.StripeInformationProvider
public int getStripeCount()
getStripeCount
in interface StripeCompactionPolicy.StripeInformationProvider
public java.util.Collection<HStoreFile> getUnneededFiles(long maxTs, java.util.List<HStoreFile> filesCompacting)
public double getCompactionPressure()
public java.util.Comparator<HStoreFile> getStoreFileComparator()