org.apache.hadoop.hbase.coprocessor

Class TestRegionServerObserver.CPRegionServerObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.BaseRegionServerObserver

org.apache.hadoop.hbase.coprocessor.TestRegionServerObserver.CPRegionServerObserver

All Implemented Interfaces:

Coprocessor, RegionServerObserver

Enclosing class:

TestRegionServerObserver

public static class TestRegionServerObserver.CPRegionServerObserver
extends BaseRegionServerObserver

Nested Class Summary

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

Coprocessor.State

Field Summary

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

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
CPRegionServerObserver()

Method Summary

Modifier and Type	Method and Description
void	postMerge(ObserverContext<RegionServerCoprocessorEnvironment> c, Region regionA, Region regionB, Region mergedRegion) called after the regions merge.
void	postMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB, Region mr) This will be called after PONR step as part of regions merge transaction.
void	postRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB) This will be called after the roll back of the regions merge.
void	preMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB) Called before the regions merge.
void	preMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB, List<Mutation> metaEntries) This will be called before PONR step as part of regions merge transaction.
void	preRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB) This will be called before the roll back of the regions merge.
void	resetStates()
boolean	wasPostMergeCalled()
boolean	wasPostMergeCommit()
boolean	wasPostRollBackMerge()
boolean	wasPreMergeCalled()
boolean	wasPreMergeCommit()
boolean	wasPreRollBackMerge()
boolean	wasRegionMergeCalled()

Methods inherited from class org.apache.hadoop.hbase.coprocessor.BaseRegionServerObserver

postCreateReplicationEndPoint, postReplicateLogEntries, postRollWALWriterRequest, preReplicateLogEntries, preRollWALWriterRequest, preStopRegionServer, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

CPRegionServerObserver

public CPRegionServerObserver()

Method Detail

resetStates

public void resetStates()

preMerge

public void preMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
                     Region regionA,
                     Region regionB)
              throws IOException

Description copied from interface: RegionServerObserver

Called before the regions merge. Call ObserverContext.bypass() to skip the merge.

Specified by:

preMerge in interface RegionServerObserver

Overrides:

preMerge in class BaseRegionServerObserver

Throws:

IOException - if an error occurred on the coprocessor

preMergeCommit

public void preMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
                           Region regionA,
                           Region regionB,
                           List<Mutation> metaEntries)
                    throws IOException

Description copied from interface: RegionServerObserver

This will be called before PONR step as part of regions merge transaction. Calling ObserverContext.bypass() rollback the merge

Specified by:

preMergeCommit in interface RegionServerObserver

Overrides:

preMergeCommit in class BaseRegionServerObserver

metaEntries - mutations to execute on hbase:meta atomically with regions merge updates. Any puts or deletes to execute on hbase:meta can be added to the mutations.

Throws:

IOException

postMergeCommit

public void postMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
                            Region regionA,
                            Region regionB,
                            Region mr)
                     throws IOException

Description copied from interface: RegionServerObserver

This will be called after PONR step as part of regions merge transaction.

Specified by:

postMergeCommit in interface RegionServerObserver

Overrides:

postMergeCommit in class BaseRegionServerObserver

Throws:

IOException

preRollBackMerge

public void preRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
                             Region regionA,
                             Region regionB)
                      throws IOException

Description copied from interface: RegionServerObserver

This will be called before the roll back of the regions merge.

Specified by:

preRollBackMerge in interface RegionServerObserver

Overrides:

preRollBackMerge in class BaseRegionServerObserver

Throws:

IOException

postRollBackMerge

public void postRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
                              Region regionA,
                              Region regionB)
                       throws IOException

Description copied from interface: RegionServerObserver

This will be called after the roll back of the regions merge.

Specified by:

postRollBackMerge in interface RegionServerObserver

Overrides:

postRollBackMerge in class BaseRegionServerObserver

Throws:

IOException

postMerge

public void postMerge(ObserverContext<RegionServerCoprocessorEnvironment> c,
                      Region regionA,
                      Region regionB,
                      Region mergedRegion)
               throws IOException

Description copied from interface: RegionServerObserver

called after the regions merge.

Specified by:

postMerge in interface RegionServerObserver

Overrides:

postMerge in class BaseRegionServerObserver

Throws:

IOException

wasPreMergeCalled

public boolean wasPreMergeCalled()

wasPostMergeCalled

public boolean wasPostMergeCalled()

wasPreMergeCommit

public boolean wasPreMergeCommit()

wasPostMergeCommit

public boolean wasPostMergeCommit()

wasPreRollBackMerge

public boolean wasPreRollBackMerge()

wasPostRollBackMerge

public boolean wasPostRollBackMerge()

wasRegionMergeCalled

public boolean wasRegionMergeCalled()