public static class TestPassCustomCellViaRegionObserver.RegionObserverImpl extends Object implements org.apache.hadoop.hbase.coprocessor.RegionCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionObserver
Modifier and Type | Field and Description |
---|---|
(package private) static AtomicInteger |
COUNT |
Constructor and Description |
---|
RegionObserverImpl() |
Modifier and Type | Method and Description |
---|---|
Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver> |
getRegionObserver() |
org.apache.hadoop.hbase.client.Result |
preAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
org.apache.hadoop.hbase.client.Append append) |
boolean |
preCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.CompareOperator op,
org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
org.apache.hadoop.hbase.client.Delete delete,
boolean result) |
boolean |
preCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.CompareOperator op,
org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
org.apache.hadoop.hbase.client.Put put,
boolean result) |
void |
preDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
org.apache.hadoop.hbase.client.Delete delete,
org.apache.hadoop.hbase.wal.WALEdit edit,
org.apache.hadoop.hbase.client.Durability durability) |
org.apache.hadoop.hbase.client.Result |
preIncrement(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
org.apache.hadoop.hbase.client.Increment increment) |
void |
prePut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
org.apache.hadoop.hbase.client.Put put,
org.apache.hadoop.hbase.wal.WALEdit edit,
org.apache.hadoop.hbase.client.Durability durability) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getBulkLoadObserver, getEndpointObserver
postAppend, postAppend, postAppendBeforeWAL, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndDelete, postCheckAndMutate, postCheckAndPut, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactSelection, postDelete, postDelete, postExists, postFlush, postFlush, postGetOp, postIncrement, postIncrement, postIncrementBeforeWAL, postInstantiateDeleteTracker, postMemStoreCompaction, postMutationBeforeWAL, postOpen, postPut, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndDeleteAfterRowLock, preCheckAndMutate, preCheckAndMutateAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preCheckAndPutAfterRowLock, preClose, preCommitStoreFile, preCompact, preCompactScannerOpen, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preGetOp, preIncrement, preIncrementAfterRowLock, preMemStoreCompaction, preMemStoreCompactionCompact, preMemStoreCompactionCompactScannerOpen, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen, preStoreScannerOpen, preWALAppend, preWALRestore
static final AtomicInteger COUNT
public RegionObserverImpl()
public Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver> getRegionObserver()
getRegionObserver
in interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor
public void prePut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Put put, org.apache.hadoop.hbase.wal.WALEdit edit, org.apache.hadoop.hbase.client.Durability durability) throws IOException
prePut
in interface org.apache.hadoop.hbase.coprocessor.RegionObserver
IOException
public void preDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Delete delete, org.apache.hadoop.hbase.wal.WALEdit edit, org.apache.hadoop.hbase.client.Durability durability) throws IOException
preDelete
in interface org.apache.hadoop.hbase.coprocessor.RegionObserver
IOException
public boolean preCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.CompareOperator op, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Put put, boolean result) throws IOException
preCheckAndPut
in interface org.apache.hadoop.hbase.coprocessor.RegionObserver
IOException
public boolean preCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.CompareOperator op, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Delete delete, boolean result) throws IOException
preCheckAndDelete
in interface org.apache.hadoop.hbase.coprocessor.RegionObserver
IOException
public org.apache.hadoop.hbase.client.Result preAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Append append) throws IOException
preAppend
in interface org.apache.hadoop.hbase.coprocessor.RegionObserver
IOException
public org.apache.hadoop.hbase.client.Result preIncrement(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Increment increment) throws IOException
preIncrement
in interface org.apache.hadoop.hbase.coprocessor.RegionObserver
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.