org.apache.hadoop.hbase.coprocessor.example

类 ScanModifyingObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.example.ScanModifyingObserver

所有已实现的接口:

Coprocessor, RegionCoprocessor, RegionObserver

@InterfaceAudience.Private
public class ScanModifyingObserver
extends Object
implements RegionCoprocessor, RegionObserver

A RegionObserver which modifies incoming Scan requests to include additional columns than what the user actually requested.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.hadoop.hbase.Coprocessor

Coprocessor.State

从接口继承的嵌套类/接口 org.apache.hadoop.hbase.coprocessor.RegionObserver

RegionObserver.MutationType

字段概要

字段

限定符和类型	字段和说明
static String	FAMILY_TO_ADD_KEY
static String	QUALIFIER_TO_ADD_KEY

从接口继承的字段 org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

构造器概要

构造器

构造器和说明
ScanModifyingObserver()

方法概要

限定符和类型	方法和说明
Optional<RegionObserver>	getRegionObserver()
void	preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan)
void	start(CoprocessorEnvironment env)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

getBulkLoadObserver, getEndpointObserver

从接口继承的方法 org.apache.hadoop.hbase.Coprocessor

getServices, stop

从接口继承的方法 org.apache.hadoop.hbase.coprocessor.RegionObserver

postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactSelection, postDelete, postExists, postFlush, postFlush, postGetOp, postIncrement, postInstantiateDeleteTracker, postMemStoreCompaction, postMutationBeforeWAL, postOpen, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCommitStoreFile, preCompact, preCompactScannerOpen, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preGetOp, preIncrement, preIncrementAfterRowLock, preMemStoreCompaction, preMemStoreCompactionCompact, preMemStoreCompactionCompactScannerOpen, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preStoreFileReaderOpen, preStoreScannerOpen, preWALRestore

字段详细资料

FAMILY_TO_ADD_KEY

public static final String FAMILY_TO_ADD_KEY

另请参阅:

常量字段值

QUALIFIER_TO_ADD_KEY

public static final String QUALIFIER_TO_ADD_KEY

另请参阅:

常量字段值

构造器详细资料

ScanModifyingObserver

public ScanModifyingObserver()

方法详细资料

start

public void start(CoprocessorEnvironment env)
           throws IOException

指定者:

start 在接口中 Coprocessor

抛出:

IOException

getRegionObserver

public Optional<RegionObserver> getRegionObserver()

指定者:

getRegionObserver 在接口中 RegionCoprocessor

preScannerOpen

public void preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
                           Scan scan)
                    throws IOException

指定者:

preScannerOpen 在接口中 RegionObserver

抛出:

IOException