Package org.apache.hadoop.hbase.coprocessor

Class TestCoprocessorMetrics.CustomWALObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestCoprocessorMetrics.CustomWALObserver

All Implemented Interfaces:

org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.WALCoprocessor, org.apache.hadoop.hbase.coprocessor.WALObserver

Enclosing class:

TestCoprocessorMetrics

public static class TestCoprocessorMetrics.CustomWALObserver
extends Object
implements org.apache.hadoop.hbase.coprocessor.WALCoprocessor, org.apache.hadoop.hbase.coprocessor.WALObserver

WALObserver that has a Counter for walEdits written.

Nested Class Summary

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

org.apache.hadoop.hbase.Coprocessor.State

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.metrics.Counter	walEditsCount

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

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor	Description
CustomWALObserver()

Method Summary

Modifier and Type	Method	Description
Optional<org.apache.hadoop.hbase.coprocessor.WALObserver>	getWALObserver()
void	postWALWrite(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.client.RegionInfo info, org.apache.hadoop.hbase.wal.WALKey logKey, org.apache.hadoop.hbase.wal.WALEdit logEdit)
void	start(org.apache.hadoop.hbase.CoprocessorEnvironment env)

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, stop

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

postWALRoll, preWALRoll, preWALWrite

Field Details

walEditsCount

private org.apache.hadoop.hbase.metrics.Counter walEditsCount

Constructor Details

CustomWALObserver

public CustomWALObserver()

Method Details

postWALWrite

public void postWALWrite(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment> ctx,
 org.apache.hadoop.hbase.client.RegionInfo info,
 org.apache.hadoop.hbase.wal.WALKey logKey,
 org.apache.hadoop.hbase.wal.WALEdit logEdit)
                  throws IOException

Specified by:

postWALWrite in interface org.apache.hadoop.hbase.coprocessor.WALObserver

Throws:

IOException

start

public void start(org.apache.hadoop.hbase.CoprocessorEnvironment env)
           throws IOException

Specified by:

start in interface org.apache.hadoop.hbase.Coprocessor

Throws:

IOException

getWALObserver

public Optional<org.apache.hadoop.hbase.coprocessor.WALObserver> getWALObserver()

Specified by:

getWALObserver in interface org.apache.hadoop.hbase.coprocessor.WALCoprocessor