hadoop - 用于辅助的用户定义 HBase 协处理器实现

Question

我正在尝试在我的系统上本地添加用户定义的协处理器用于辅助存储目的，我引用了“https://www.3pillarglobal.com/insights/hbase-coprocessors”链接来实现。这样做时，当我尝试加载静态协处理器时，我收到了一些与 RegionCoprocessor 相关的错误，说提到的 classed 不是 RegionCoprocessor 的类型。请帮助我完成此功能。

DatabaseCrudCoprocessor.java > 实现 >

 @InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
@InterfaceStability.Evolving
public class DatabaseCrudCoprocessor  implements RegionObserver {
    private static final String className = "DatabaseCrudCoprocessor";
    private static JsonObject object = new JsonObject();
    static final CloudLogger logger = CloudLogger.getLogger("DatabaseCrudCoprocessor");


    public void postPut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability)
            throws IOException {
        try {
            Connection con = c.getEnvironment().getConnection();
            logger.info("---------------------This Code Is Excecute---------------------------");
        }catch(Exception e) {
            logger.error("In "+className+" postPut : Exception : "+e);
        }
    }
}

HBase 上的 Log.Errors >> >

Hadoop-Master >>>>>>

SLF4J: Class path contains multiple SLF4J bindings.

SLF4J:在 [jar:file:/home/hadoop/hbase/hbase/lib/demo-0.0.2-SNAPSHOT-jar-with-dependencies.jar!/org/slf4j/impl/StaticLoggerBinder.class] 中找到绑定(bind)
SLF4J:在 [jar:file:/home/hadoop/hbase/hbase/lib/phoenix-5.0.0-HBase-2.0-client.jar!/org/slf4j/impl/StaticLoggerBinder.class] 中找到绑定(bind)
SLF4J:在 [jar:file:/home/hadoop/hbase/hbase/lib/phoenix-5.0.0-HBase-2.0-hive.jar!/org/slf4j/impl/StaticLoggerBinder.class] 中找到绑定(bind)
SLF4J:在 [jar:file:/home/hadoop/hbase/hbase/lib/phoenix-5.0.0-HBase-2.0-pig.jar!/org/slf4j/impl/StaticLoggerBinder.class] 中找到绑定(bind)
SLF4J:在 [jar:file:/home/hadoop/hbase/hbase/lib/phoenix-5.0.0-HBase-2.0-thin-client.jar!/org/slf4j/impl/StaticLoggerBinder.class] 中找到绑定(bind)
SLF4J:在 [jar:file:/home/hadoop/hbase/hbase/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 中找到绑定(bind)
SLF4J:见 http://www.slf4j.org/codes.html#multiple_bindings解释一下。
SLF4J:实际绑定(bind)的类型为 [org.slf4j.impl.Log4jLoggerFactory]
0 [RS-EventLoopGroup-1-2] INFO SecurityLogger.org.apache.hadoop.hbase.Server - 来自 127.0.0.1:45903 的连接，版本 = 2.2.2，sasl = false，ugi = hadoop (auth:SIMPLE)，服务=区域服务器状态服务
1266 [master/localhost:60000:becomeActiveMaster] 错误 org.apache.hadoop.hbase.master.RegionServerTracker - localhost,60020,1576052978374 没有匹配的 ServerCrashProcedure
1266 [master/localhost:60000:becomeActiveMaster] 错误 org.apache.hadoop.hbase.master.RegionServerTracker - localhost,60020,1539250172019 没有匹配的 ServerCrashProcedure
1266 [master/localhost:60000:becomeActiveMaster] 错误 org.apache.hadoop.hbase.master.RegionServerTracker - localhost,60020,1576071410923 没有匹配的 ServerCrashProcedure
1266 [master/localhost:60000:becomeActiveMaster] 错误 org.apache.hadoop.hbase.master.RegionServerTracker - localhost,60020,1576127072238 没有匹配的 ServerCrashProcedure

在 RegionServer >>>>>>>>

0    [RS-EventLoopGroup-1-3] INFO  SecurityLogger.org.apache.hadoop.hbase.Server  - Connection from 127.0.0.1:33828, version=2.2.2, sasl=false, ugi=hadoop (auth:SIMPLE), service=AdminService

167 [RS_CLOSE_META-regionserver/localhost:60020-0] 错误 org.apache.hadoop.hbase.regionserver.RegionCoprocessorHost - demo.DatabaseCrudCoprocessor 不是 RegionCoprocessor 类型。检查 hbase.coprocessor.region.classes 的配置
167 [RS_CLOSE_META-regionserver/localhost:60020-0] 错误 org.apache.hadoop.hbase.coprocessor.CoprocessorHost - 无法加载协处理器 DatabaseCrudCoprocessor
1302 [RS-EventLoopGroup-1-4] 信息 SecurityLogger.org.apache.hadoop.hbase.Server - 来自 127.0.0.1:33830 的连接，版本 = 2.2.2，sasl = false，ugi = hadoop(身份验证:简单)，服务=客户服务

Answer 1

尝试实现 RegionCoprocessor 和 RegionObserver
并覆盖 getRegionObserver() 方法。如果您使用的是 hbase 2.0 版本

  public class RegionObserverExample implements RegionCoprocessor, RegionObserver {
         @Override
        public Optional<RegionObserver> getRegionObserver() {
          return Optional.of(this);
        }
       ...
     }