| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.regionserver | |
| org.apache.hadoop.hbase.regionserver.compactions | |
| org.apache.hadoop.hbase.regionserver.querymatcher | 
| Modifier and Type | Field and Description | 
|---|---|
private ScanInfo | 
CustomizedScanInfoBuilder.scanInfo  | 
private ScanInfo | 
HStore.scanInfo  | 
| Modifier and Type | Method and Description | 
|---|---|
ScanInfo | 
CustomizedScanInfoBuilder.build()  | 
(package private) ScanInfo | 
ScanInfo.customize(int maxVersions,
         long ttl,
         KeepDeletedCells keepDeletedCells)
Used for CP users for customizing max versions, ttl and keepDeletedCells. 
 | 
ScanInfo | 
HStore.getScanInfo()  | 
ScanInfo | 
RegionCoprocessorHost.preCompactScannerOpen(HStore store,
                     ScanType scanType,
                     CompactionLifeCycleTracker tracker,
                     CompactionRequest request,
                     User user)
Called prior to opening store scanner for compaction. 
 | 
ScanInfo | 
RegionCoprocessorHost.preFlushScannerOpen(HStore store,
                   FlushLifeCycleTracker tracker)
Invoked before create StoreScanner for flush. 
 | 
ScanInfo | 
RegionCoprocessorHost.preMemStoreCompactionCompactScannerOpen(HStore store)
Invoked before create StoreScanner for in memory compaction. 
 | 
ScanInfo | 
RegionCoprocessorHost.preStoreScannerOpen(HStore store)
Called before open store scanner for user scan. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected KeyValueScanner | 
HMobStore.createScanner(Scan scan,
             ScanInfo scanInfo,
             NavigableSet<byte[]> targetCols,
             long readPt)
Gets the MobStoreScanner or MobReversedStoreScanner. 
 | 
protected KeyValueScanner | 
HStore.createScanner(Scan scan,
             ScanInfo scanInfo,
             NavigableSet<byte[]> targetCols,
             long readPt)  | 
private void | 
StoreScanner.seekAllScanner(ScanInfo scanInfo,
              List<? extends KeyValueScanner> scanners)  | 
(package private) void | 
HStore.setScanInfo(ScanInfo scanInfo)
Set scan info, used by test 
 | 
| Constructor and Description | 
|---|
CustomizedScanInfoBuilder(ScanInfo scanInfo)  | 
MobStoreScanner(HStore store,
               ScanInfo scanInfo,
               Scan scan,
               NavigableSet<byte[]> columns,
               long readPt)  | 
ReversedMobStoreScanner(HStore store,
                       ScanInfo scanInfo,
                       Scan scan,
                       NavigableSet<byte[]> columns,
                       long readPt)  | 
ReversedStoreScanner(HStore store,
                    ScanInfo scanInfo,
                    Scan scan,
                    NavigableSet<byte[]> columns,
                    long readPt)
Opens a scanner across memstore, snapshot, and all StoreFiles. 
 | 
ReversedStoreScanner(Scan scan,
                    ScanInfo scanInfo,
                    NavigableSet<byte[]> columns,
                    List<? extends KeyValueScanner> scanners)
Constructor for testing. 
 | 
StoreScanner(HStore store,
            ScanInfo scanInfo,
            List<? extends KeyValueScanner> scanners,
            long smallestReadPoint,
            long earliestPutTs,
            byte[] dropDeletesFromRow,
            byte[] dropDeletesToRow)
Used for compactions that drop deletes from a limited range of rows. 
 | 
StoreScanner(HStore store,
            ScanInfo scanInfo,
            List<? extends KeyValueScanner> scanners,
            ScanType scanType,
            long smallestReadPoint,
            long earliestPutTs)
Used for store file compaction and memstore compaction. 
 | 
StoreScanner(HStore store,
            ScanInfo scanInfo,
            List<? extends KeyValueScanner> scanners,
            ScanType scanType,
            long smallestReadPoint,
            long earliestPutTs,
            byte[] dropDeletesFromRow,
            byte[] dropDeletesToRow)  | 
StoreScanner(HStore store,
            ScanInfo scanInfo,
            Scan scan,
            NavigableSet<byte[]> columns,
            long readPt)
Opens a scanner across memstore, snapshot, and all StoreFiles. 
 | 
StoreScanner(HStore store,
            Scan scan,
            ScanInfo scanInfo,
            int numColumns,
            long readPt,
            boolean cacheBlocks,
            ScanType scanType)
An internal constructor. 
 | 
StoreScanner(ScanInfo scanInfo,
            int maxVersions,
            ScanType scanType,
            List<? extends KeyValueScanner> scanners)  | 
StoreScanner(ScanInfo scanInfo,
            ScanType scanType,
            List<? extends KeyValueScanner> scanners)  | 
StoreScanner(Scan scan,
            ScanInfo scanInfo,
            NavigableSet<byte[]> columns,
            List<? extends KeyValueScanner> scanners)  | 
| Modifier and Type | Method and Description | 
|---|---|
private ScanInfo | 
Compactor.preCompactScannerOpen(CompactionRequestImpl request,
                     ScanType scanType,
                     User user)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected InternalScanner | 
Compactor.createScanner(HStore store,
             ScanInfo scanInfo,
             List<StoreFileScanner> scanners,
             long smallestReadPoint,
             long earliestPutTs,
             byte[] dropDeletesFromRow,
             byte[] dropDeletesToRow)  | 
protected InternalScanner | 
Compactor.createScanner(HStore store,
             ScanInfo scanInfo,
             List<StoreFileScanner> scanners,
             ScanType scanType,
             long smallestReadPoint,
             long earliestPutTs)  | 
InternalScanner | 
StripeCompactor.StripeInternalScannerFactory.createScanner(ScanInfo scanInfo,
             List<StoreFileScanner> scanners,
             ScanType scanType,
             Compactor.FileDetails fd,
             long smallestReadPoint)  | 
InternalScanner | 
Compactor.InternalScannerFactory.createScanner(ScanInfo scanInfo,
             List<StoreFileScanner> scanners,
             ScanType scanType,
             Compactor.FileDetails fd,
             long smallestReadPoint)  | 
| Modifier and Type | Method and Description | 
|---|---|
static CompactionScanQueryMatcher | 
CompactionScanQueryMatcher.create(ScanInfo scanInfo,
      ScanType scanType,
      long readPointToUse,
      long earliestPutTs,
      long oldestUnexpiredTS,
      long now,
      byte[] dropDeletesFromRow,
      byte[] dropDeletesToRow,
      RegionCoprocessorHost regionCoprocessorHost)  | 
static RawScanQueryMatcher | 
RawScanQueryMatcher.create(Scan scan,
      ScanInfo scanInfo,
      ColumnTracker columns,
      boolean hasNullColumn,
      long oldestUnexpiredTS,
      long now)  | 
static NormalUserScanQueryMatcher | 
NormalUserScanQueryMatcher.create(Scan scan,
      ScanInfo scanInfo,
      ColumnTracker columns,
      DeleteTracker deletes,
      boolean hasNullColumn,
      long oldestUnexpiredTS,
      long now)  | 
static UserScanQueryMatcher | 
UserScanQueryMatcher.create(Scan scan,
      ScanInfo scanInfo,
      NavigableSet<byte[]> columns,
      long oldestUnexpiredTS,
      long now,
      RegionCoprocessorHost regionCoprocessorHost)  | 
private static Cell | 
UserScanQueryMatcher.createStartKey(Scan scan,
              ScanInfo scanInfo)  | 
protected static Cell | 
ScanQueryMatcher.createStartKeyFromRow(byte[] startRow,
                     ScanInfo scanInfo)  | 
protected static Pair<DeleteTracker,ColumnTracker> | 
ScanQueryMatcher.getTrackers(RegionCoprocessorHost host,
           NavigableSet<byte[]> columns,
           ScanInfo scanInfo,
           long oldestUnexpiredTS,
           Scan userScan)  | 
| Constructor and Description | 
|---|
CompactionScanQueryMatcher(ScanInfo scanInfo,
                          DeleteTracker deletes,
                          ColumnTracker columnTracker,
                          long readPointToUse,
                          long oldestUnexpiredTS,
                          long now)  | 
DropDeletesCompactionScanQueryMatcher(ScanInfo scanInfo,
                                     DeleteTracker deletes,
                                     ColumnTracker columns,
                                     long readPointToUse,
                                     long earliestPutTs,
                                     long oldestUnexpiredTS,
                                     long now)  | 
IncludeAllCompactionQueryMatcher(ScanInfo scanInfo,
                                DeleteTracker deletes,
                                ColumnTracker columns,
                                long readPointToUse,
                                long oldestUnexpiredTS,
                                long now)  | 
MajorCompactionScanQueryMatcher(ScanInfo scanInfo,
                               DeleteTracker deletes,
                               ColumnTracker columns,
                               long readPointToUse,
                               long earliestPutTs,
                               long oldestUnexpiredTS,
                               long now)  | 
MinorCompactionScanQueryMatcher(ScanInfo scanInfo,
                               DeleteTracker deletes,
                               ColumnTracker columns,
                               long readPointToUse,
                               long oldestUnexpiredTS,
                               long now)  | 
NormalUserScanQueryMatcher(Scan scan,
                          ScanInfo scanInfo,
                          ColumnTracker columns,
                          boolean hasNullColumn,
                          DeleteTracker deletes,
                          long oldestUnexpiredTS,
                          long now)  | 
RawScanQueryMatcher(Scan scan,
                   ScanInfo scanInfo,
                   ColumnTracker columns,
                   boolean hasNullColumn,
                   long oldestUnexpiredTS,
                   long now)  | 
ScanQueryMatcher(Cell startKey,
                ScanInfo scanInfo,
                ColumnTracker columns,
                long oldestUnexpiredTS,
                long now)  | 
StripeCompactionScanQueryMatcher(ScanInfo scanInfo,
                                DeleteTracker deletes,
                                ColumnTracker columns,
                                long readPointToUse,
                                long earliestPutTs,
                                long oldestUnexpiredTS,
                                long now,
                                byte[] dropDeletesFromRow,
                                byte[] dropDeletesToRow)  | 
UserScanQueryMatcher(Scan scan,
                    ScanInfo scanInfo,
                    ColumnTracker columns,
                    boolean hasNullColumn,
                    long oldestUnexpiredTS,
                    long now)  | 
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.