public static class TestRegionServerObserver.CPRegionServerObserver extends BaseRegionServerObserver
Coprocessor.State
PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION
Constructor and Description |
---|
CPRegionServerObserver() |
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,
java.util.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() |
postCreateReplicationEndPoint, postReplicateLogEntries, postRollWALWriterRequest, preReplicateLogEntries, preRollWALWriterRequest, preStopRegionServer, start, stop
public void resetStates()
public void preMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB) throws java.io.IOException
RegionServerObserver
ObserverContext.bypass()
to skip the merge.preMerge
in interface RegionServerObserver
preMerge
in class BaseRegionServerObserver
java.io.IOException
- if an error occurred on the coprocessorpublic void preMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB, java.util.List<Mutation> metaEntries) throws java.io.IOException
RegionServerObserver
ObserverContext.bypass()
rollback the mergepreMergeCommit
in interface RegionServerObserver
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.java.io.IOException
public void postMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB, Region mr) throws java.io.IOException
RegionServerObserver
postMergeCommit
in interface RegionServerObserver
postMergeCommit
in class BaseRegionServerObserver
java.io.IOException
public void preRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB) throws java.io.IOException
RegionServerObserver
preRollBackMerge
in interface RegionServerObserver
preRollBackMerge
in class BaseRegionServerObserver
java.io.IOException
public void postRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA, Region regionB) throws java.io.IOException
RegionServerObserver
postRollBackMerge
in interface RegionServerObserver
postRollBackMerge
in class BaseRegionServerObserver
java.io.IOException
public void postMerge(ObserverContext<RegionServerCoprocessorEnvironment> c, Region regionA, Region regionB, Region mergedRegion) throws java.io.IOException
RegionServerObserver
postMerge
in interface RegionServerObserver
postMerge
in class BaseRegionServerObserver
java.io.IOException
public boolean wasPreMergeCalled()
public boolean wasPostMergeCalled()
public boolean wasPreMergeCommit()
public boolean wasPostMergeCommit()
public boolean wasPreRollBackMerge()
public boolean wasPostRollBackMerge()
public boolean wasRegionMergeCalled()