Modifier and Type | Method and Description |
---|---|
InternalScanner |
ZooKeeperScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s) |
InternalScanner |
ZooKeeperScanPolicyObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s) |
Modifier and Type | Method and Description |
---|---|
InternalScanner |
ZooKeeperScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s) |
InternalScanner |
ZooKeeperScanPolicyObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s) |
Modifier and Type | Interface and Description |
---|---|
interface |
RegionScanner
RegionScanner describes iterators over rows in an HRegion.
|
Modifier and Type | Class and Description |
---|---|
class |
KeyValueHeap
Implements a heap merge across any number of KeyValueScanners.
|
class |
ReversedKeyValueHeap
ReversedKeyValueHeap is used for supporting reversed scanning.
|
class |
StoreScanner
Scanner scans both the memstore and the Store.
|
Modifier and Type | Method and Description |
---|---|
InternalScanner |
RegionCoprocessorHost.preCompact(Store store,
InternalScanner scanner,
ScanType scanType,
CompactionRequest request)
Called prior to rewriting the store files selected for compaction
|
InternalScanner |
RegionCoprocessorHost.preCompactScannerOpen(Store store,
List<StoreFileScanner> scanners,
ScanType scanType,
long earliestPutTs,
CompactionRequest request,
long readPoint)
|
InternalScanner |
RegionCoprocessorHost.preFlush(Store store,
InternalScanner scanner)
Invoked before a memstore flush
|
InternalScanner |
RegionCoprocessorHost.preFlushScannerOpen(Store store,
KeyValueScanner memstoreScanner,
long readPoint)
|
Modifier and Type | Method and Description |
---|---|
void |
RegionCoprocessorHost.postScannerClose(InternalScanner s) |
boolean |
RegionCoprocessorHost.postScannerFilterRow(InternalScanner s,
byte[] currentRow,
int offset,
short length)
This will be called by the scan flow when the current scanned row is being filtered out by the
filter.
|
boolean |
RegionCoprocessorHost.postScannerNext(InternalScanner s,
List<Result> results,
int limit,
boolean hasMore) |
InternalScanner |
RegionCoprocessorHost.preCompact(Store store,
InternalScanner scanner,
ScanType scanType,
CompactionRequest request)
Called prior to rewriting the store files selected for compaction
|
InternalScanner |
RegionCoprocessorHost.preFlush(Store store,
InternalScanner scanner)
Invoked before a memstore flush
|
boolean |
RegionCoprocessorHost.preScannerClose(InternalScanner s) |
Boolean |
RegionCoprocessorHost.preScannerNext(InternalScanner s,
List<Result> results,
int limit) |
Modifier and Type | Method and Description |
---|---|
InternalScanner |
Compactor.InternalScannerFactory.createScanner(List<StoreFileScanner> scanners,
ScanType scanType,
Compactor.FileDetails fd,
long smallestReadPoint) |
protected InternalScanner |
Compactor.createScanner(Store store,
List<StoreFileScanner> scanners,
long smallestReadPoint,
long earliestPutTs,
byte[] dropDeletesFromRow,
byte[] dropDeletesToRow) |
protected InternalScanner |
Compactor.createScanner(Store store,
List<StoreFileScanner> scanners,
ScanType scanType,
long smallestReadPoint,
long earliestPutTs) |
protected InternalScanner |
Compactor.postCreateCoprocScanner(CompactionRequest request,
ScanType scanType,
InternalScanner scanner,
User user)
Calls coprocessor, if any, to create scanners - after normal scanner creation.
|
protected InternalScanner |
Compactor.preCreateCoprocScanner(CompactionRequest request,
ScanType scanType,
long earliestPutTs,
List<StoreFileScanner> scanners,
User user,
long readPoint)
Calls coprocessor, if any, to create compaction scanner - before normal scanner creation.
|
Modifier and Type | Method and Description |
---|---|
S |
Compactor.CellSinkFactory.createWriter(InternalScanner scanner,
Compactor.FileDetails fd,
boolean shouldDropBehind) |
protected void |
AbstractMultiOutputCompactor.initMultiWriter(AbstractMultiFileWriter writer,
InternalScanner scanner,
Compactor.FileDetails fd,
boolean shouldDropBehind) |
protected boolean |
Compactor.performCompaction(InternalScanner scanner,
Compactor.CellSink writer,
long smallestReadPoint,
boolean cleanSeqId,
ThroughputController throughputController)
Performs the compaction.
|
protected InternalScanner |
Compactor.postCreateCoprocScanner(CompactionRequest request,
ScanType scanType,
InternalScanner scanner,
User user)
Calls coprocessor, if any, to create scanners - after normal scanner creation.
|
Modifier and Type | Method and Description |
---|---|
InternalScanner |
AccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType) |
Modifier and Type | Method and Description |
---|---|
void |
AccessController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c,
InternalScanner s) |
InternalScanner |
AccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType) |
void |
AccessController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c,
InternalScanner s) |
boolean |
AccessController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c,
InternalScanner s,
List<Result> result,
int limit,
boolean hasNext) |
Modifier and Type | Method and Description |
---|---|
void |
VisibilityController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c,
InternalScanner s) |
void |
VisibilityController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c,
InternalScanner s) |
boolean |
VisibilityController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c,
InternalScanner s,
List<Result> result,
int limit,
boolean hasNext) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.