Uses of Class
org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl
Package
Description
-
Uses of CompactionRequestImpl in org.apache.hadoop.hbase.mob
Modifier and TypeMethodDescriptionprotected List<org.apache.hadoop.fs.Path>
DefaultMobStoreCompactor.commitWriter
(StoreFileWriter writer, Compactor.FileDetails fd, CompactionRequestImpl request) List<org.apache.hadoop.fs.Path>
DefaultMobStoreCompactor.compact
(CompactionRequestImpl request, ThroughputController throughputController, User user) protected boolean
DefaultMobStoreCompactor.performCompaction
(Compactor.FileDetails fd, InternalScanner scanner, CellSink writer, long smallestReadPoint, boolean cleanSeqId, ThroughputController throughputController, CompactionRequestImpl request, CompactionProgress progress) Performs compaction on a column family with the mob flag enabled.private StoreFileWriter
DefaultMobStoreCompactor.switchToNewMobWriter
(StoreFileWriter mobFileWriter, Compactor.FileDetails fd, long mobCells, boolean major, CompactionRequestImpl request, List<String> committedMobWriterFileNames) -
Uses of CompactionRequestImpl in org.apache.hadoop.hbase.regionserver
Modifier and TypeMethodDescriptionprotected List<HStoreFile>
HStore.doCompaction
(CompactionRequestImpl cr, Collection<HStoreFile> filesToCompact, User user, long compactionStartTime, List<org.apache.hadoop.fs.Path> newFiles) protected void
HStore.finishCompactionRequest
(CompactionRequestImpl cr) void
DateTieredStoreEngine.DateTieredCompactionContext.forceSelect
(CompactionRequestImpl request) void
StripeStoreEngine.StripeCompaction.forceSelect
(CompactionRequestImpl request) private void
HStore.logCompactionEndMessage
(CompactionRequestImpl cr, List<HStoreFile> sfs, long now, long compactionStartTime) Log a very elaborate compaction completion message. -
Uses of CompactionRequestImpl in org.apache.hadoop.hbase.regionserver.compactions
Modifier and TypeFieldDescriptionprotected CompactionRequestImpl
CompactionContext.request
protected CompactionRequestImpl
StripeCompactionPolicy.StripeCompactionRequest.request
Modifier and TypeMethodDescriptionprotected CompactionRequestImpl
DateTieredCompactionPolicy.createCompactionRequest
(ArrayList<HStoreFile> candidateSelection, boolean tryingMajor, boolean mayUseOffPeak, boolean mayBeStuck) protected CompactionRequestImpl
RatioBasedCompactionPolicy.createCompactionRequest
(ArrayList<HStoreFile> candidateSelection, boolean tryingMajor, boolean mayUseOffPeak, boolean mayBeStuck) protected abstract CompactionRequestImpl
SortedCompactionPolicy.createCompactionRequest
(ArrayList<HStoreFile> candidateSelection, boolean tryingMajor, boolean mayUseOffPeak, boolean mayBeStuck) CompactionContext.getRequest()
StripeCompactionPolicy.StripeCompactionRequest.getRequest()
FIFOCompactionPolicy.selectCompaction
(Collection<HStoreFile> candidateFiles, List<HStoreFile> filesCompacting, boolean isUserCompaction, boolean mayUseOffPeak, boolean forceMajor) SortedCompactionPolicy.selectCompaction
(Collection<HStoreFile> candidateFiles, List<HStoreFile> filesCompacting, boolean isUserCompaction, boolean mayUseOffPeak, boolean forceMajor) DateTieredCompactionPolicy.selectMajorCompaction
(ArrayList<HStoreFile> candidateSelection) DateTieredCompactionPolicy.selectMinorCompaction
(ArrayList<HStoreFile> candidateSelection, boolean mayUseOffPeak, boolean mayBeStuck) We receive store files sorted in ascending order by seqId then scan the list of files.Modifier and TypeMethodDescriptionprotected abstract List<org.apache.hadoop.fs.Path>
Compactor.commitWriter
(T writer, Compactor.FileDetails fd, CompactionRequestImpl request) protected List<org.apache.hadoop.fs.Path>
DateTieredCompactor.commitWriter
(DateTieredMultiFileWriter writer, Compactor.FileDetails fd, CompactionRequestImpl request) protected List<org.apache.hadoop.fs.Path>
DefaultCompactor.commitWriter
(StoreFileWriter writer, Compactor.FileDetails fd, CompactionRequestImpl request) protected List<org.apache.hadoop.fs.Path>
StripeCompactor.commitWriter
(StripeMultiFileWriter writer, Compactor.FileDetails fd, CompactionRequestImpl request) protected final List<org.apache.hadoop.fs.Path>
Compactor.compact
(CompactionRequestImpl request, Compactor.InternalScannerFactory scannerFactory, Compactor.CellSinkFactory<T> sinkFactory, ThroughputController throughputController, User user) List<org.apache.hadoop.fs.Path>
DateTieredCompactor.compact
(CompactionRequestImpl request, List<Long> lowerBoundaries, Map<Long, String> lowerBoundariesPolicies, ThroughputController throughputController, User user) List<org.apache.hadoop.fs.Path>
DefaultCompactor.compact
(CompactionRequestImpl request, ThroughputController throughputController, User user) Do a minor/major compaction on an explicit set of storefiles from a Store.List<org.apache.hadoop.fs.Path>
StripeCompactor.compact
(CompactionRequestImpl request, int targetCount, long targetSize, byte[] left, byte[] right, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user) List<org.apache.hadoop.fs.Path>
StripeCompactor.compact
(CompactionRequestImpl request, List<byte[]> targetBoundaries, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user) StripeCompactionPolicy.createEmptyRequest
(StripeCompactionPolicy.StripeInformationProvider si, CompactionRequestImpl request) void
CompactionContext.forceSelect
(CompactionRequestImpl request) Forces external selection to be applied for this compaction.Compactor.InternalScannerFactory.getScanType
(CompactionRequestImpl request) StripeCompactor.StripeInternalScannerFactory.getScanType
(CompactionRequestImpl request) private boolean
DateTieredCompactor.needEmptyFile
(CompactionRequestImpl request) protected boolean
Compactor.performCompaction
(Compactor.FileDetails fd, InternalScanner scanner, CellSink writer, long smallestReadPoint, boolean cleanSeqId, ThroughputController throughputController, CompactionRequestImpl request, CompactionProgress progress) Performs the compaction.private InternalScanner
Compactor.postCompactScannerOpen
(CompactionRequestImpl request, ScanType scanType, InternalScanner scanner, User user) Calls coprocessor, if any, to create scanners - after normal scanner creation.private ScanInfo
Compactor.preCompactScannerOpen
(CompactionRequestImpl request, ScanType scanType, User user) void
StripeCompactionPolicy.StripeCompactionRequest.setRequest
(CompactionRequestImpl request) ModifierConstructorDescriptionBoundaryStripeCompactionRequest
(CompactionRequestImpl request, List<byte[]> targetBoundaries) SplitStripeCompactionRequest
(CompactionRequestImpl request, byte[] startRow, byte[] endRow, int targetCount, long targetKvs)