温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

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

发布时间:2021-11-24 14:25:45 来源:亿速云 阅读:359 作者:iii 栏目:大数据

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

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI