HBase Java Client内部线程池应用场景与连接分析
更新:HHH   时间:2023-1-7


这篇文章主要介绍“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内部线程池应用场景与连接分析”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注天达云网站,小编会继续努力为大家带来更多实用的文章!

返回大数据教程...