@InterfaceAudience.LimitedPrivate(value="Coprocesssor")
@InterfaceStability.Evolving
public interface Store
Modifier and Type | Field and Description |
---|---|
static int |
NO_PRIORITY |
static int |
PRIORITY_USER
The default priority for user-specified compaction requests.
|
Modifier and Type | Method and Description |
---|---|
boolean |
areWritesEnabled() |
boolean |
canSplit()
Returns whether this store is splittable, i.e., no reference file in this store.
|
OptionalDouble |
getAvgStoreFileAge() |
ColumnFamilyDescriptor |
getColumnFamilyDescriptor() |
String |
getColumnFamilyName() |
long |
getCompactedCellsCount() |
long |
getCompactedCellsSize() |
Collection<? extends StoreFile> |
getCompactedFiles() |
int |
getCompactedFilesCount() |
double |
getCompactionPressure()
This value can represent the degree of emergency of compaction for this store.
|
int |
getCompactPriority() |
CellComparator |
getComparator() |
int |
getCurrentParallelPutCount() |
org.apache.hadoop.fs.FileSystem |
getFileSystem() |
MemStoreSize |
getFlushableSize() |
long |
getFlushedCellsCount() |
long |
getFlushedCellsSize() |
long |
getFlushedOutputFileSize() |
long |
getHFilesSize() |
long |
getLastCompactSize() |
long |
getMajorCompactedCellsCount() |
long |
getMajorCompactedCellsSize() |
OptionalLong |
getMaxMemStoreTS() |
OptionalLong |
getMaxSequenceId() |
OptionalLong |
getMaxStoreFileAge() |
MemStoreSize |
getMemStoreSize() |
OptionalLong |
getMinStoreFileAge() |
long |
getNumHFiles() |
long |
getNumReferenceFiles() |
RegionInfo |
getRegionInfo() |
long |
getSize() |
long |
getSmallestReadPoint() |
MemStoreSize |
getSnapshotSize() |
Collection<? extends StoreFile> |
getStorefiles() |
int |
getStorefilesCount() |
long |
getStorefilesRootLevelIndexSize() |
long |
getStorefilesSize() |
long |
getStoreSizeUncompressed() |
TableName |
getTableName() |
long |
getTotalStaticBloomSize()
Returns the total byte size of all Bloom filter bit arrays.
|
long |
getTotalStaticIndexSize()
Returns the total size of all index blocks in the data block indexes, including the root level,
intermediate levels, and the leaf level for multi-level indexes, or just the root level for
single-level indexes.
|
boolean |
hasReferences() |
boolean |
hasTooManyStoreFiles() |
boolean |
isPrimaryReplicaStore() |
boolean |
isSloppyMemStore() |
boolean |
needsCompaction()
See if there's too much store files in this store
|
void |
refreshStoreFiles()
Checks the underlying store files, and opens the files that have not been opened, and removes
the store file readers for store files no longer available.
|
boolean |
shouldPerformMajorCompaction()
Tests whether we should run a major compaction.
|
long |
timeOfOldestEdit()
When was the last edit done in the memstore
|
static final int PRIORITY_USER
static final int NO_PRIORITY
CellComparator getComparator()
Collection<? extends StoreFile> getStorefiles()
Collection<? extends StoreFile> getCompactedFiles()
long timeOfOldestEdit()
org.apache.hadoop.fs.FileSystem getFileSystem()
boolean shouldPerformMajorCompaction() throws IOException
IOException
boolean needsCompaction()
true
if number of store files is greater than the number defined in
minFilesToCompactint getCompactPriority()
boolean canSplit()
boolean hasReferences()
true
if the store has any underlying reference files to older HFilesMemStoreSize getMemStoreSize()
MemStoreSize getFlushableSize()
getMemStoreSize()
unless we are carrying snapshots and then it will be the size of
outstanding snapshots.MemStoreSize getSnapshotSize()
ColumnFamilyDescriptor getColumnFamilyDescriptor()
OptionalLong getMaxSequenceId()
OptionalLong getMaxMemStoreTS()
long getLastCompactSize()
long getSize()
int getStorefilesCount()
int getCompactedFilesCount()
OptionalLong getMaxStoreFileAge()
OptionalLong getMinStoreFileAge()
OptionalDouble getAvgStoreFileAge()
long getNumReferenceFiles()
long getNumHFiles()
long getStoreSizeUncompressed()
long getStorefilesSize()
long getHFilesSize()
long getStorefilesRootLevelIndexSize()
long getTotalStaticIndexSize()
long getTotalStaticBloomSize()
RegionInfo getRegionInfo()
boolean areWritesEnabled()
long getSmallestReadPoint()
String getColumnFamilyName()
TableName getTableName()
long getFlushedCellsCount()
long getFlushedCellsSize()
long getFlushedOutputFileSize()
long getCompactedCellsCount()
long getCompactedCellsSize()
long getMajorCompactedCellsCount()
long getMajorCompactedCellsSize()
boolean hasTooManyStoreFiles()
void refreshStoreFiles() throws IOException
IOException
double getCompactionPressure()
And for striped stores, we should calculate this value by the files in each stripe separately and return the maximum value.
It is similar to getCompactPriority()
except that it is more suitable to use in a
linear formula.
boolean isPrimaryReplicaStore()
boolean isSloppyMemStore()
int getCurrentParallelPutCount()
Copyright © 2007–2019 Cloudera. All rights reserved.