HBase Java Client内部线程池应用场景与连接分析

这篇文章主要介绍“HBase Java Client内部线程池应用场景与连接分析”，在日常操作中，相信很多人在HBase Java Client内部线程池应用场景与连接分析问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”HBase Java Client内部线程池应用场景与连接分析”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

对于调用batch 相关方法 才会用到线程池相关内容

下图是 Dao对象 connection 对象内部参数

构造Connection

在分布式环境下，客户端访问 HBase 需要通过 ZooKeeper 的地址和端口来获取当前活跃的 Master 和所需的 RegionServer 地址。因此需要先用 HBaseCongifiguration 类配置 ZooKeeper 的地址和端口，然后再使用 Connection 类建立连接。

关于一下代码 connection 是单例模式

@Bean

public Connection instance() throws Exception {  

Configuration config =HBaseConfiguration.create();  

config.set(HConstants.ZOOKEEPER_QUORUM, zooKeeper);  

config.set(HConstants.ZOOKEEPER_CLIENT_PORT, "2181");  

config.set(HConstants.ZOOKEEPER_ZNODE_PARENT, nodeParent);  

return ConnectionFactory.createConnection(config,   Executors.newFixedThreadPool(20));}

线程池是为批量操作而生

获取Table对象 如果没有传递线程池pool参数。会默认是生成一个。

如何根据rowkey 查找region?

到此，关于“HBase Java Client内部线程池应用场景与连接分析”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！