org.apache.hadoop.hbase.coprocessor.example

类 ValueRewritingObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.example.ValueRewritingObserver

所有已实现的接口:

Coprocessor, RegionCoprocessor, RegionObserver

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

This RegionObserver replaces the values of Puts from one value to another on compaction.

嵌套类概要

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

RegionObserver.MutationType

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

Coprocessor.State

字段概要

字段

限定符和类型	字段和说明
static String	ORIGINAL_VALUE_KEY
static String	REPLACED_VALUE_KEY

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

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

构造器概要

构造器

构造器和说明
ValueRewritingObserver()

方法概要

限定符和类型	方法和说明
Optional<RegionObserver>	getRegionObserver()
InternalScanner	preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request)
void	start(CoprocessorEnvironment env)

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

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

从接口继承的方法 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, preCompactScannerOpen, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preGetOp, preIncrement, preIncrementAfterRowLock, preMemStoreCompaction, preMemStoreCompactionCompact, preMemStoreCompactionCompactScannerOpen, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen, preStoreScannerOpen, preWALRestore

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

getBulkLoadObserver, getEndpointObserver

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

getServices, stop

字段详细资料

ORIGINAL_VALUE_KEY

public static final String ORIGINAL_VALUE_KEY

另请参阅:

常量字段值

REPLACED_VALUE_KEY

public static final String REPLACED_VALUE_KEY

另请参阅:

常量字段值

构造器详细资料

ValueRewritingObserver

public ValueRewritingObserver()

方法详细资料

getRegionObserver

public Optional<RegionObserver> getRegionObserver()

指定者:

getRegionObserver 在接口中 RegionCoprocessor

start

public void start(CoprocessorEnvironment env)
           throws IOException

指定者:

start 在接口中 Coprocessor

抛出:

IOException

preCompact

public InternalScanner preCompact(ObserverContext<RegionCoprocessorEnvironment> c,
                                  Store store,
                                  InternalScanner scanner,
                                  ScanType scanType,
                                  CompactionLifeCycleTracker tracker,
                                  CompactionRequest request)

指定者:

preCompact 在接口中 RegionObserver