HBaseJavaClient内部线程池应用场景与连接分析

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

成都创新互联公司专注于桐庐网站建设服务及定制,我们拥有丰富的企业做网站经验。 热诚为您提供桐庐营销型网站建设,桐庐网站制作、桐庐网页设计、桐庐网站官网定制、微信小程序服务,打造桐庐网络公司原创品牌,更为您提供桐庐网站排名全网营销落地服务。

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

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

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

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

构造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));}

线程池是为批量操作而生

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

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

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

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

如何根据rowkey 查找region?

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

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


网页标题:HBaseJavaClient内部线程池应用场景与连接分析
本文URL:http://scyanting.com/article/ispide.html