Modifier and Type | Method and Description |
---|---|
default InternalScanner |
RegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
ScanType scanType,
CompactionLifeCycleTracker tracker,
CompactionRequest request)
Called prior to writing the
StoreFile s selected for compaction into a new
StoreFile . |
default void |
RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
ScanType scanType,
ScanOptions options,
CompactionLifeCycleTracker tracker,
CompactionRequest request)
Called before we open store scanner for compaction.
|
Modifier and Type | Method and Description |
---|---|
private StoreScanner |
PartitionedMobCompactor.createScanner(List<HStoreFile> filesToCompact,
ScanType scanType)
Creates a store scanner.
|
Modifier and Type | Method and Description |
---|---|
static ScanType |
ScanType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ScanType[] |
ScanType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
InternalScanner |
RegionCoprocessorHost.preCompact(HStore store,
InternalScanner scanner,
ScanType scanType,
CompactionLifeCycleTracker tracker,
CompactionRequest request,
User user)
Called prior to rewriting the store files selected for compaction
|
ScanInfo |
RegionCoprocessorHost.preCompactScannerOpen(HStore store,
ScanType scanType,
CompactionLifeCycleTracker tracker,
CompactionRequest request,
User user)
Called prior to opening store scanner for compaction.
|
Constructor and Description |
---|
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,
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,
ScanType scanType) |
Modifier and Type | Method and Description |
---|---|
ScanType |
Compactor.InternalScannerFactory.getScanType(CompactionRequestImpl request) |
ScanType |
StripeCompactor.StripeInternalScannerFactory.getScanType(CompactionRequestImpl request) |
Modifier and Type | Method and Description |
---|---|
protected InternalScanner |
Compactor.createScanner(HStore store,
ScanInfo scanInfo,
List<StoreFileScanner> scanners,
ScanType scanType,
long smallestReadPoint,
long earliestPutTs) |
InternalScanner |
Compactor.InternalScannerFactory.createScanner(ScanInfo scanInfo,
List<StoreFileScanner> scanners,
ScanType scanType,
Compactor.FileDetails fd,
long smallestReadPoint) |
InternalScanner |
StripeCompactor.StripeInternalScannerFactory.createScanner(ScanInfo scanInfo,
List<StoreFileScanner> scanners,
ScanType scanType,
Compactor.FileDetails fd,
long smallestReadPoint) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
InternalScanner |
AccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
ScanType scanType,
CompactionLifeCycleTracker tracker,
CompactionRequest request) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.