Uses of Class
org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl
Packages that use CompactionRequestImpl
Package
Description
-
Uses of CompactionRequestImpl in org.apache.hadoop.hbase.mob
Methods in org.apache.hadoop.hbase.mob with parameters of type CompactionRequestImplModifier 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 booleanDefaultMobStoreCompactor.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 StoreFileWriterDefaultMobStoreCompactor.switchToNewMobWriter(StoreFileWriter mobFileWriter, Compactor.FileDetails fd, long mobCells, boolean major, CompactionRequestImpl request, List<String> committedMobWriterFileNames) -
Uses of CompactionRequestImpl in org.apache.hadoop.hbase.regionserver
Methods in org.apache.hadoop.hbase.regionserver with parameters of type CompactionRequestImplModifier and TypeMethodDescriptionprotected List<HStoreFile>HStore.doCompaction(CompactionRequestImpl cr, Collection<HStoreFile> filesToCompact, User user, long compactionStartTime, List<org.apache.hadoop.fs.Path> newFiles) protected voidHStore.finishCompactionRequest(CompactionRequestImpl cr) voidDateTieredStoreEngine.DateTieredCompactionContext.forceSelect(CompactionRequestImpl request) voidStripeStoreEngine.StripeCompaction.forceSelect(CompactionRequestImpl request) private voidHStore.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
Subclasses of CompactionRequestImpl in org.apache.hadoop.hbase.regionserver.compactionsFields in org.apache.hadoop.hbase.regionserver.compactions declared as CompactionRequestImplModifier and TypeFieldDescriptionprotected CompactionRequestImplCompactionContext.requestprotected CompactionRequestImplStripeCompactionPolicy.StripeCompactionRequest.requestMethods in org.apache.hadoop.hbase.regionserver.compactions that return CompactionRequestImplModifier and TypeMethodDescriptionprotected CompactionRequestImplDateTieredCompactionPolicy.createCompactionRequest(ArrayList<HStoreFile> candidateSelection, boolean tryingMajor, boolean mayUseOffPeak, boolean mayBeStuck) protected CompactionRequestImplRatioBasedCompactionPolicy.createCompactionRequest(ArrayList<HStoreFile> candidateSelection, boolean tryingMajor, boolean mayUseOffPeak, boolean mayBeStuck) protected abstract CompactionRequestImplSortedCompactionPolicy.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.Methods in org.apache.hadoop.hbase.regionserver.compactions with parameters of type CompactionRequestImplModifier 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) voidCompactionContext.forceSelect(CompactionRequestImpl request) Forces external selection to be applied for this compaction.Compactor.InternalScannerFactory.getScanType(CompactionRequestImpl request) StripeCompactor.StripeInternalScannerFactory.getScanType(CompactionRequestImpl request) private booleanDateTieredCompactor.needEmptyFile(CompactionRequestImpl request) protected booleanCompactor.performCompaction(Compactor.FileDetails fd, InternalScanner scanner, CellSink writer, long smallestReadPoint, boolean cleanSeqId, ThroughputController throughputController, CompactionRequestImpl request, CompactionProgress progress) Performs the compaction.private InternalScannerCompactor.postCompactScannerOpen(CompactionRequestImpl request, ScanType scanType, InternalScanner scanner, User user) Calls coprocessor, if any, to create scanners - after normal scanner creation.private ScanInfoCompactor.preCompactScannerOpen(CompactionRequestImpl request, ScanType scanType, User user) voidStripeCompactionPolicy.StripeCompactionRequest.setRequest(CompactionRequestImpl request) Constructors in org.apache.hadoop.hbase.regionserver.compactions with parameters of type CompactionRequestImplModifierConstructorDescriptionBoundaryStripeCompactionRequest(CompactionRequestImpl request, List<byte[]> targetBoundaries) SplitStripeCompactionRequest(CompactionRequestImpl request, byte[] startRow, byte[] endRow, int targetCount, long targetKvs)