重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
这篇文章主要介绍“HBase Java Client内部线程池应用场景与连接分析”,在日常操作中,相信很多人在HBase Java Client内部线程池应用场景与连接分析问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”HBase Java Client内部线程池应用场景与连接分析”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
成都创新互联公司专注于桐庐网站建设服务及定制,我们拥有丰富的企业做网站经验。 热诚为您提供桐庐营销型网站建设,桐庐网站制作、桐庐网页设计、桐庐网站官网定制、微信小程序服务,打造桐庐网络公司原创品牌,更为您提供桐庐网站排名全网营销落地服务。
下图是 Dao对象 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参数。会默认是生成一个。
到此,关于“HBase Java Client内部线程池应用场景与连接分析”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注创新互联网站,小编会继续努力为大家带来更多实用的文章!