这篇文章主要介绍“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内部线程池应用场景与连接分析”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。