Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-21794 Update the Coprocessor observer example given in section 111.1 of the ref guide.

Browse Source 
Signed-off-by: Sean Busbey <busbey@apache.org>
This commit is contained in:
Sakthi 2019-01-30 13:08:31 -08:00 committed by Sean Busbey
parent 81ebe6d40d
commit 64c32720d6
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/asciidoc/_chapters/cp.adoc
View File

@ -483,6 +483,7 @@ The following Observer coprocessor prevents the details of the user `admin` from
returned in a `Get` or `Scan` of the `users` table. returned in a `Get` or `Scan` of the `users` table.
. Write a class that implements the . Write a class that implements the
link:https://hbase.apache.org/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionCoprocessor.html[RegionCoprocessor],
link:https://hbase.apache.org/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html[RegionObserver] link:https://hbase.apache.org/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html[RegionObserver]
class. class.
@ -500,16 +501,20 @@ empty result. Otherwise, process the request as normal.
Following are the implementation of the above steps: Following are the implementation of the above steps:
[source,java] [source,java]
---- ----
public class RegionObserverExample implements RegionObserver { public class RegionObserverExample implements RegionCoprocessor, RegionObserver {
private static final byte[] ADMIN = Bytes.toBytes("admin"); private static final byte[] ADMIN = Bytes.toBytes("admin");
private static final byte[] COLUMN_FAMILY = Bytes.toBytes("details"); private static final byte[] COLUMN_FAMILY = Bytes.toBytes("details");
private static final byte[] COLUMN = Bytes.toBytes("Admin_det"); private static final byte[] COLUMN = Bytes.toBytes("Admin_det");
private static final byte[] VALUE = Bytes.toBytes("You can't see Admin details"); private static final byte[] VALUE = Bytes.toBytes("You can't see Admin details");
@Override
public Optional<RegionObserver> getRegionObserver() {
return Optional.of(this);
}
@Override @Override
public void preGetOp(final ObserverContext<RegionCoprocessorEnvironment> e, final Get get, final List<Cell> results) public void preGetOp(final ObserverContext<RegionCoprocessorEnvironment> e, final Get get, final List<Cell> results)
throws IOException { throws IOException {