hbase获取region以及读取每个region的第一行
hbase获取region以及读取每个region的第一行
@(HBASE)[hbase]
1、通过HRegionInfo可以获取region的详细信息
2、Scan#setBatch(1)可以指定每次读取多少行,但必须马上Scan#close(),否则会一直读下去。
private static void checkTable(String tabName) {TableName tn = TableName.valueOf(tabName);Configuration config = HBaseConfiguration.create();HRegionInfo regionInfo;try (Connection connection = ConnectionFactory.createConnection(config);Admin admin = connection.getAdmin();Table table = connection.getTable(tn);) {if(!admin.tableExists(TableName.valueOf(tabName))){addAlarm(AlarmType.TABLE_NOT_FOUND,tabName);return;}List<HRegionInfo> lr = admin.getTableRegions(tn);Result r = null;if(lr == null){log.warn("No region found for table " + tabName);}// 遍历表的每个regionIterator<HRegionInfo> ir = lr.iterator();while (ir.hasNext()) {regionInfo = ir.next();ResultScanner scanner = null;Long startTime = System.currentTimeMillis();byte[] startRowkey = regionInfo.getStartKey();Scan sc = new Scan();sc.setBatch(1);sc.setStartRow(startRowkey);try {scanner = table.getScanner(sc);r = scanner.next();scanner.close();} catch (Exception e) {}}
hbase获取region以及读取每个region的第一行相关推荐
- 最通俗易懂的解释hbase热点问题rowkey设计原则region分区及解决方案
关于热点问题,我简单陈述容易理解: 我们最开始hbase创建表默认是一个region,而我们所谓的热点问题其实就是对某一个region的过量访问造成的 Hbase当发现一个region存储数据量大于阈 ...
- hbase获取表信息_HBase的读写和javaAPI的使用
一.hbase系统管理表 hbase:namespace,记录了hbase中所有namespace的信息 ,当前系统下有哪些namespace信息 scan 'hbase:namespace' hba ...
- android 读取文件内容,Android读写文件 获取文件并读取写入数据
一. 从 resource 中的 raw 文件夹中获取文件并读取数据(资源文件只能读不能写) String res = ""; try{ InputStream in ...
- 3.6.3 获取分区的读取偏移量
3.6.3 获取分区的读取偏移量 读取分区的偏移量涉及日志存储,这里我们先给出一些简单的结论(具体细节会在第6章详细分析):一个分区有多个片段文件(Segment),每个片段文件都包含全局有序的片段基 ...
- 企业微信开发文档接口API获取accesstoken和读取成员内部员工
企业微信开发文档接口API获取accesstoken和读取成员内部员工 <?php /*** 企业微信 API*/ namespace app\common;use think\Config; ...
- Apache POI和EasyExcel 第七集:EasyExcel的基本操作,读取和写入Excel,一行足矣
Apache POI和EasyExcel 第七集:EasyExcel的基本操作,读取和写入Excel,一行搞定 一.资源 在这里设置lombok会遇到一个问题,以前在springboot那里都没遇到, ...
- java读取文件指定内容_Java读取文本指定的某一行内容
Java读取文本指定的某一行内容,使用的都是IO的方法,下面具体看例子: /** * @author:罗大锤 * @date: 2017年9月6日 下午2:35:43 * @version 1.0 * ...
- dos bat批处理的魅力 批处理读取文本中的每一行 操作文件
dos bat批处理的魅力 批处理读取文本中的每一行 操作文件 http://blog.sina.com.cn/s/blog_872457fd0100tasi.html 批处理读取文本中的每一 行 ( ...
- python读excel成数组_python 如何读取excel文件 将每一行存为数组/python读程序题
python 如何读取excel文件 将每一行存为数组 from xlrd import open_workbook wb=open_workbook(r'd:/222.xlsx') tb=wb.sh ...
最新文章
- 行为型模式:命令模式
- 《埃森哲技术展望2016》解密未来企业竞争究竟拼什么?
- Computer Science Theory for the Information Age-3: 高维空间中的高斯分布和随机投影
- linux怎么对端口限速,linux – 如何使用iptables对SSH连接进行速率限制?
- 我的LAMP源码编译安装linux+Apache+mysql+php
- 华为VLAN间互访配置
- [asp.net mvc]自定义filter
- 详解:MySQL数据库的权限管理和运维实操
- 狂砸250多亿!亚马逊花了7年时间,造了一个让你自愿加班到死的办公室!
- Intel CPU命名规则
- Python解答蓝桥杯省赛真题之从入门到真题
- 压力传感器的常见螺纹
- 验证苹果手机正品新机
- 计算机常用的内存是rom,手机内存和电脑内存是一样的吗?智能硬件常用的ROM和RAM详解...
- 小胡网创:读书和赚钱是一个人一生最好的修行
- 匠心独运解读Mybatis源码,纯手工打造开源框架
- SAP-ABAP-如何查找系统中已经存在的增强(包括1代2代3代BTE表字段增强等)和标准的增强点
- Joint Pose and Expression Modeling for Facial Expression Recognition 论文翻译
- SAP 特别总账标识和备选统驭科目
- linux关闭硬盘检测,关闭Linux开机强制检测硬盘
热门文章
- Vue指令篇_v-bind
- 【leetcode-83】剑指 Offer 18-2 删除排序链表中的重复元素
- 【已解决】Error attaching to process: sun.jvm.hotspot.runtime.VMVersionMismatchException: Supported versi
- mysql 磁盘利用率100_磁盘空间使用率100%的故障处理
- k8s多节点仪表盘(web界面)部署与谷歌浏览器访问k8s仪表盘问题解决!
- 在jsp页面实现保存登录用户名和密码
- php链接mysql验证用户登录,PHP连接mysql验证用户名是否存在
- 计算机入域时域控用到的端口,【ADDC】域控需要开放的端口
- html下拉列表插件,js+CSS实现模拟华丽的select控件下拉菜单效果
- octave安装 缺java_Octave信号包安装