Package | Description |
---|---|
org.apache.hadoop.hbase.constraint |
Restrict the domain of a data attribute, often times to fulfill business rules/requirements.
|
org.apache.hadoop.hbase.mapreduce |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.mob | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.compactions |
Modifier and Type | Method and Description |
---|---|
boolean |
ConstraintProcessor.postScannerFilterRow(<any> e,
InternalScanner s,
Cell curRowCell,
boolean hasMore) |
Modifier and Type | Method and Description |
---|---|
boolean |
IntegrationTestBulkLoad.SlowMeCoproScanOperations.preScannerNext(<any> e,
InternalScanner s,
java.util.List<Result> results,
int limit,
boolean hasMore) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
DefaultMobStoreCompactor.performCompaction(Compactor.FileDetails fd,
InternalScanner scanner,
CellSink writer,
long smallestReadPoint,
boolean cleanSeqId,
ThroughputController throughputController,
boolean major,
int numofFilesToCompact)
Performs compaction on a column family with the mob flag enabled.
|
protected void |
DefaultMobStoreFlusher.performMobFlush(MemStoreSnapshot snapshot,
long cacheFlushId,
InternalScanner scanner,
StoreFileWriter writer,
MonitoredTask status,
ThroughputController throughputController)
Flushes the cells in the mob store.
|
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 |
MobStoreScanner
Scanner scans both the memstore and the MOB Store.
|
class |
ReversedKeyValueHeap
ReversedKeyValueHeap is used for supporting reversed scanning.
|
class |
ReversedStoreScanner
ReversedStoreScanner extends from StoreScanner, and is used to support
reversed scanning.
|
class |
StoreScanner
Scanner scans both the memstore and the Store.
|
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
|
InternalScanner |
RegionCoprocessorHost.preFlush(HStore store,
InternalScanner scanner,
FlushLifeCycleTracker tracker)
Invoked before a memstore flush
|
InternalScanner |
RegionCoprocessorHost.preMemStoreCompactionCompact(HStore store,
InternalScanner scanner)
Invoked before compacting memstore.
|
Modifier and Type | Method and Description |
---|---|
void |
RegionCoprocessorHost.postScannerClose(InternalScanner s) |
boolean |
RegionCoprocessorHost.postScannerFilterRow(InternalScanner s,
Cell curRowCell)
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,
java.util.List<Result> results,
int limit,
boolean hasMore) |
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
|
InternalScanner |
RegionCoprocessorHost.preFlush(HStore store,
InternalScanner scanner,
FlushLifeCycleTracker tracker)
Invoked before a memstore flush
|
InternalScanner |
RegionCoprocessorHost.preMemStoreCompactionCompact(HStore store,
InternalScanner scanner)
Invoked before compacting memstore.
|
boolean |
RegionCoprocessorHost.preScannerClose(InternalScanner s)
Supports Coprocessor 'bypass'.
|
java.lang.Boolean |
RegionCoprocessorHost.preScannerNext(InternalScanner s,
java.util.List<Result> results,
int limit) |
Modifier and Type | Method and Description |
---|---|
protected InternalScanner |
Compactor.createScanner(HStore store,
ScanInfo scanInfo,
java.util.List<StoreFileScanner> scanners,
long smallestReadPoint,
long earliestPutTs,
byte[] dropDeletesFromRow,
byte[] dropDeletesToRow) |
protected InternalScanner |
Compactor.createScanner(HStore store,
ScanInfo scanInfo,
java.util.List<StoreFileScanner> scanners,
ScanType scanType,
long smallestReadPoint,
long earliestPutTs) |
InternalScanner |
Compactor.InternalScannerFactory.createScanner(ScanInfo scanInfo,
java.util.List<StoreFileScanner> scanners,
ScanType scanType,
Compactor.FileDetails fd,
long smallestReadPoint) |
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(Compactor.FileDetails fd,
InternalScanner scanner,
CellSink writer,
long smallestReadPoint,
boolean cleanSeqId,
ThroughputController throughputController,
boolean major,
int numofFilesToCompact)
Performs the compaction.
|