| Package | Description |
|---|---|
| org.apache.hadoop.hbase.mob | |
| org.apache.hadoop.hbase.mob.compactions | |
| org.apache.hadoop.hbase.regionserver |
| Modifier and Type | Method and Description |
|---|---|
static void |
MobUtils.removeMobFiles(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
TableName tableName,
org.apache.hadoop.fs.Path tableDir,
byte[] family,
Collection<HStoreFile> storeFiles)
Archives the mob files.
|
| Constructor and Description |
|---|
CachedMobFile(HStoreFile sf) |
MobFile(HStoreFile sf) |
| Modifier and Type | Method and Description |
|---|---|
List<HStoreFile> |
PartitionedMobCompactionRequest.CompactionDelPartition.getStoreFiles() |
| Modifier and Type | Method and Description |
|---|---|
void |
PartitionedMobCompactionRequest.CompactionDelPartition.addStoreFile(HStoreFile file) |
| Modifier and Type | Method and Description |
|---|---|
protected HStoreFile |
HStore.createStoreFileAndReader(org.apache.hadoop.fs.Path p) |
| Modifier and Type | Method and Description |
|---|---|
Collection<HStoreFile> |
StoreFileManager.clearCompactedFiles()
Clears all the compacted files and returns them.
|
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableCollection<HStoreFile> |
StripeStoreFileManager.clearCompactedFiles() |
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableCollection<HStoreFile> |
StoreFileManager.clearFiles()
Clears all the files currently in use and returns them.
|
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableCollection<HStoreFile> |
StripeStoreFileManager.clearFiles() |
Map<byte[],List<HStoreFile>> |
HRegion.close()
Close down this HRegion.
|
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableCollection<HStoreFile> |
HStore.close()
Close all the readers We don't need to worry about subsequent requests because the Region holds
a write lock that will prevent any more reads or writes.
|
Map<byte[],List<HStoreFile>> |
HRegion.close(boolean abort)
Close down this HRegion.
|
List<HStoreFile> |
HStore.compact(org.apache.hadoop.hbase.regionserver.compactions.CompactionContext compaction,
ThroughputController throughputController,
User user)
Compact the StoreFiles.
|
protected List<HStoreFile> |
HStore.doCompaction(org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl cr,
Collection<HStoreFile> filesToCompact,
User user,
long compactionStartTime,
List<org.apache.hadoop.fs.Path> newFiles) |
Iterator<HStoreFile> |
StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue targetKey)
Gets initial, full list of candidate store files to check for row-key-before.
|
Iterator<HStoreFile> |
StripeStoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue targetKey)
See
StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue)
for details on this methods. |
Collection<HStoreFile> |
StoreFileManager.getCompactedfiles()
List of compacted files inside this store that needs to be excluded in reads
because further new reads will be using only the newly created files out of compaction.
|
Collection<HStoreFile> |
StripeStoreFileManager.getCompactedfiles() |
Collection<HStoreFile> |
HStore.getCompactedFiles() |
Collection<HStoreFile> |
StoreFileManager.getFilesForScan(byte[] startRow,
boolean includeStartRow,
byte[] stopRow,
boolean includeStopRow)
Gets the store files to scan for a Scan or Get request.
|
Collection<HStoreFile> |
StripeStoreFileManager.getFilesForScan(byte[] startRow,
boolean includeStartRow,
byte[] stopRow,
boolean includeStopRow) |
List<HStoreFile> |
StripeStoreFileManager.getLevel0Files() |
Comparator<HStoreFile> |
StoreFileManager.getStoreFileComparator() |
Comparator<HStoreFile> |
StripeStoreFileManager.getStoreFileComparator() |
Collection<HStoreFile> |
StoreFileManager.getStorefiles()
Gets the snapshot of the store files currently in use.
|
Collection<HStoreFile> |
StripeStoreFileManager.getStorefiles() |
Collection<HStoreFile> |
HStore.getStorefiles() |
ArrayList<org.apache.hbase.thirdparty.com.google.common.collect.ImmutableList<HStoreFile>> |
StripeStoreFileManager.getStripes() |
Collection<HStoreFile> |
StoreFileManager.getUnneededFiles(long maxTs,
List<HStoreFile> filesCompacting) |
Collection<HStoreFile> |
StripeStoreFileManager.getUnneededFiles(long maxTs,
List<HStoreFile> filesCompacting) |
Iterator<HStoreFile> |
StoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator<HStoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
Updates the candidate list for finding row key before.
|
Iterator<HStoreFile> |
StripeStoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator<HStoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
See
StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue) and
StoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator, KeyValue, Cell)
for details on this methods. |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.fs.Path |
HRegionFileSystem.mergeStoreFile(RegionInfo mergedRegion,
String familyName,
HStoreFile f,
org.apache.hadoop.fs.Path mergedDir)
Write out a merge reference under the given merges directory.
|
void |
RegionCoprocessorHost.postCompact(HStore store,
HStoreFile resultFile,
org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request,
User user)
Called after the store compaction has completed.
|
void |
RegionCoprocessorHost.postFlush(HStore store,
HStoreFile storeFile,
FlushLifeCycleTracker tracker)
Invoked after a memstore flush
|
org.apache.hadoop.fs.Path |
HRegionFileSystem.splitStoreFile(RegionInfo hri,
String familyName,
HStoreFile f,
byte[] splitRow,
boolean top,
RegionSplitPolicy splitPolicy)
Write out a split reference.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StoreFileManager.addCompactionResults(Collection<HStoreFile> compactedFiles,
Collection<HStoreFile> results)
Adds only the new compaction results into the structure.
|
void |
StoreFileManager.addCompactionResults(Collection<HStoreFile> compactedFiles,
Collection<HStoreFile> results)
Adds only the new compaction results into the structure.
|
void |
StripeStoreFileManager.addCompactionResults(Collection<HStoreFile> compactedFiles,
Collection<HStoreFile> results) |
void |
StripeStoreFileManager.addCompactionResults(Collection<HStoreFile> compactedFiles,
Collection<HStoreFile> results) |
protected void |
HStore.completeCompaction(Collection<HStoreFile> compactedFiles)
It works by processing a compaction that's been written to disk.
|
protected List<HStoreFile> |
HStore.doCompaction(org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl cr,
Collection<HStoreFile> filesToCompact,
User user,
long compactionStartTime,
List<org.apache.hadoop.fs.Path> newFiles) |
static OptionalInt |
StoreUtils.getDeterministicRandomSeed(Collection<HStoreFile> files)
Creates a deterministic hash code for store file collection.
|
static long |
StoreUtils.getLowestTimestamp(Collection<HStoreFile> candidates)
Gets lowest timestamp from candidate StoreFiles
|
static OptionalLong |
StoreUtils.getMaxMemStoreTSInList(Collection<HStoreFile> sfs)
Return the largest memstoreTS found across all storefiles in the given list.
|
static OptionalLong |
StoreUtils.getMaxSequenceIdInList(Collection<HStoreFile> sfs)
Return the highest sequence ID found across all storefiles in the given list.
|
List<KeyValueScanner> |
HStore.getScanners(List<HStoreFile> files,
boolean cacheBlocks,
boolean isGet,
boolean usePread,
boolean isCompaction,
ScanQueryMatcher matcher,
byte[] startRow,
byte[] stopRow,
long readPt,
boolean includeMemstoreScanner)
Create scanners on the given files and if needed on the memstore with no filtering based on TTL
(that happens further down the line).
|
List<KeyValueScanner> |
HStore.getScanners(List<HStoreFile> files,
boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
ScanQueryMatcher matcher,
byte[] startRow,
boolean includeStartRow,
byte[] stopRow,
boolean includeStopRow,
long readPt,
boolean includeMemstoreScanner)
Create scanners on the given files and if needed on the memstore with no filtering based on TTL
(that happens further down the line).
|
static List<StoreFileScanner> |
StoreFileScanner.getScannersForCompaction(Collection<HStoreFile> files,
boolean canUseDropBehind,
long readPt)
Get scanners for compaction.
|
static List<StoreFileScanner> |
StoreFileScanner.getScannersForStoreFiles(Collection<HStoreFile> files,
boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
boolean useDropBehind,
long readPt)
Return an array of scanners corresponding to the given set of store files.
|
static List<StoreFileScanner> |
StoreFileScanner.getScannersForStoreFiles(Collection<HStoreFile> files,
boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
boolean canUseDrop,
ScanQueryMatcher matcher,
long readPt)
Return an array of scanners corresponding to the given set of store files, And set the
ScanQueryMatcher for each store file scanner for further optimization
|
static List<StoreFileScanner> |
StoreFileScanner.getScannersForStoreFiles(Collection<HStoreFile> files,
boolean cacheBlocks,
boolean usePread,
long readPt)
Return an array of scanners corresponding to the given set of store files.
|
Collection<HStoreFile> |
StoreFileManager.getUnneededFiles(long maxTs,
List<HStoreFile> filesCompacting) |
Collection<HStoreFile> |
StripeStoreFileManager.getUnneededFiles(long maxTs,
List<HStoreFile> filesCompacting) |
static boolean |
StoreUtils.hasReferences(Collection<HStoreFile> files)
Determines whether any files in the collection are references.
|
void |
StoreFileManager.insertNewFiles(Collection<HStoreFile> sfs)
Adds new files, either for from MemStore flush or bulk insert, into the structure.
|
void |
StripeStoreFileManager.insertNewFiles(Collection<HStoreFile> sfs) |
void |
StoreFileManager.loadFiles(List<HStoreFile> storeFiles)
Loads the initial store files into empty StoreFileManager.
|
void |
StripeStoreFileManager.loadFiles(List<HStoreFile> storeFiles) |
abstract boolean |
StoreEngine.needsCompaction(List<HStoreFile> filesCompacting) |
boolean |
StripeStoreEngine.needsCompaction(List<HStoreFile> filesCompacting) |
boolean |
DateTieredStoreEngine.needsCompaction(List<HStoreFile> filesCompacting) |
boolean |
DefaultStoreEngine.needsCompaction(List<HStoreFile> filesCompacting) |
void |
RegionCoprocessorHost.postCompactSelection(HStore store,
List<HStoreFile> selected,
org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request,
User user)
Called after the
HStoreFiles to be compacted have been selected from the available
candidates. |
boolean |
RegionCoprocessorHost.preCompactSelection(HStore store,
List<HStoreFile> candidates,
org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
User user)
Called prior to selecting the
HStoreFiles for compaction from the list of currently
available candidates. |
void |
StoreFileManager.removeCompactedFiles(Collection<HStoreFile> compactedFiles)
Remove the compacted files
|
void |
StripeStoreFileManager.removeCompactedFiles(Collection<HStoreFile> compactedFiles) |
void |
HRegionFileSystem.removeStoreFiles(String familyName,
Collection<HStoreFile> storeFiles)
Closes and archives the specified store files from the specified family.
|
Iterator<HStoreFile> |
StoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator<HStoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
Updates the candidate list for finding row key before.
|
Iterator<HStoreFile> |
StripeStoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator<HStoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
See
StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue) and
StoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator, KeyValue, Cell)
for details on this methods. |
void |
ChangedReadersObserver.updateReaders(List<HStoreFile> sfs,
List<KeyValueScanner> memStoreScanners)
Notify observers.
|
void |
StoreScanner.updateReaders(List<HStoreFile> sfs,
List<KeyValueScanner> memStoreScanners) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.