Package org.apache.hadoop.hbase.coprocessor

Class MetaTableMetrics.ExampleRegionObserverMeta

java.lang.Object

org.apache.hadoop.hbase.coprocessor.MetaTableMetrics.ExampleRegionObserverMeta

All Implemented Interfaces:

Coprocessor, RegionCoprocessor, RegionObserver

Enclosing class:

MetaTableMetrics

class MetaTableMetrics.ExampleRegionObserverMeta
extends Object
implements RegionCoprocessor, RegionObserver

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

Coprocessor.State

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.coprocessor.RegionObserver

RegionObserver.MutationType

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor	Description
ExampleRegionObserverMeta()

Method Summary

Modifier and Type	Method	Description
private void	clientMetricRegisterAndMark()
private String	clientRequestMeterName(String clientIP)
private String	getRegionIdFromOp(Row op)	Get regionId from Ops such as: get, put, delete.
Optional<RegionObserver>	getRegionObserver()
private String	getTableNameFromOp(Row op)	Get table name from Ops such as: get, put, delete.
private boolean	isMetaTableOp(ObserverContext<? extends RegionCoprocessorEnvironment> e)
private String	opMeterName(Object op)
private void	opMetricRegisterAndMark(Row op)
private String	opWithClientMeterName(Object op)
private void	opWithClientMetricRegisterAndMark(Object op)
void	preDelete(ObserverContext<? extends RegionCoprocessorEnvironment> e, Delete delete, WALEdit edit, Durability durability)	Called before the client deletes a value.
void	preGetOp(ObserverContext<? extends RegionCoprocessorEnvironment> e, Get get, List<Cell> results)	Called before the client performs a Get
void	prePut(ObserverContext<? extends RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability)	Called before the client stores a value.
private String	regionMeterName(String regionId)
private void	regionMetricRegisterAndMark(Row op)
private void	registerAndMarkMeter(String requestMeter)
private void	registerAndMarkMetrics(ObserverContext<? extends RegionCoprocessorEnvironment> e, Row row)
private String	tableMeterName(String tableName)
private void	tableMetricRegisterAndMark(Row op)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.Coprocessor

getServices, start, stop

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

getBulkLoadObserver, getEndpointObserver

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionObserver

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, preAppend, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndDeleteAfterRowLock, preCheckAndMutate, preCheckAndMutateAfterRowLock, preCheckAndPut, preCheckAndPut, preCheckAndPutAfterRowLock, preCheckAndPutAfterRowLock, preClose, preCommitStoreFile, preCompact, preCompactScannerOpen, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preIncrement, preIncrement, preIncrementAfterRowLock, preMemStoreCompaction, preMemStoreCompactionCompact, preMemStoreCompactionCompactScannerOpen, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen, preStoreScannerOpen, preWALAppend

Constructor Details

ExampleRegionObserverMeta

ExampleRegionObserverMeta()

Method Details

getRegionObserver

public Optional<RegionObserver> getRegionObserver()

Specified by:

getRegionObserver in interface RegionCoprocessor

preGetOp

public void preGetOp(ObserverContext<? extends RegionCoprocessorEnvironment> e,
 Get get,
 List<Cell> results)
              throws IOException

Description copied from interface: RegionObserver

Called before the client performs a Get

Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on calling any subsequent chained coprocessors.

Specified by:

preGetOp in interface RegionObserver

Parameters:

e - the environment provided by the region server

get - the Get request

results - The result to return to the client if default processing is bypassed. Can be modified. Will not be used if default processing is not bypassed.

Throws:

IOException

prePut

public void prePut(ObserverContext<? extends RegionCoprocessorEnvironment> e,
 Put put,
 WALEdit edit,
 Durability durability)
            throws IOException

Description copied from interface: RegionObserver

Called before the client stores a value.

Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on calling any subsequent chained coprocessors.

Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If need a Cell reference for later use, copy the cell and use that.

Specified by:

prePut in interface RegionObserver

Parameters:

e - the environment provided by the region server

put - The Put object

edit - The WALEdit object that will be written to the wal

durability - Persistence guarantee for this Put

Throws:

IOException

preDelete

public void preDelete(ObserverContext<? extends RegionCoprocessorEnvironment> e,
 Delete delete,
 WALEdit edit,
 Durability durability)

Description copied from interface: RegionObserver

Called before the client deletes a value.

Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on calling any subsequent chained coprocessors.

Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If need a Cell reference for later use, copy the cell and use that.

Specified by:

preDelete in interface RegionObserver

Parameters:

e - the environment provided by the region server

delete - The Delete object

edit - The WALEdit object for the wal

durability - Persistence guarantee for this Delete

registerAndMarkMetrics

private void registerAndMarkMetrics(ObserverContext<? extends RegionCoprocessorEnvironment> e,
 Row row)

getTableNameFromOp

private String getTableNameFromOp(Row op)

Get table name from Ops such as: get, put, delete.

Parameters:

op - such as get, put or delete.

getRegionIdFromOp

private String getRegionIdFromOp(Row op)

Get regionId from Ops such as: get, put, delete.

Parameters:

op - such as get, put or delete.

isMetaTableOp

private boolean isMetaTableOp(ObserverContext<? extends RegionCoprocessorEnvironment> e)

clientMetricRegisterAndMark

private void clientMetricRegisterAndMark()

tableMetricRegisterAndMark

private void tableMetricRegisterAndMark(Row op)

regionMetricRegisterAndMark

private void regionMetricRegisterAndMark(Row op)

opMetricRegisterAndMark

private void opMetricRegisterAndMark(Row op)

opWithClientMetricRegisterAndMark

private void opWithClientMetricRegisterAndMark(Object op)

registerAndMarkMeter

private void registerAndMarkMeter(String requestMeter)

opWithClientMeterName

private String opWithClientMeterName(Object op)

opMeterName

private String opMeterName(Object op)

tableMeterName

private String tableMeterName(String tableName)

clientRequestMeterName

private String clientRequestMeterName(String clientIP)

regionMeterName

private String regionMeterName(String regionId)