Hbase JMX 监控 - Region

获取Region监控信息页面:

http://regionServerName:16030/jmx?qry=Hadoop:service=HBase,name=RegionServer,sub=Regions

 获得数据如下

参数代表含义

*** 为前缀代表:Namespace_${namespace}_table_${tableName}_region_${regionName}

 

***_metric_storeCount

当前region中store个数,即列簇个数

***_metric_storeFileCount

当前region中storeFile个数

***_metric_memStoreSize

当前region的MemStoreSize,该值达到某一特定条件会flush到磁盘,生成一个storefile,每次MemStore Flush时,会对Store进行检验,如果Store中的StoreFile数量大于hbase.hstore.compactionThreshold 时,就会触发Compaction

***_metric_storeFileSize

当前region storeFIles 大小,即每个region大小,单位为byte(字节)

***_metric_compactionsCompletedCount

完成Compaction次数

***_metric_compactionsFailedCount

Compaction失败次数

***_metric_numBytesCompactedCount

完成Compaction总大小

***_metric_numFilesCompactedCount

完成Compaction总文件数量

***_metric_readRequestCount

读请求数量,scan 1000条数据,该值会增加1000;get获取数据该数据存在会增加1,数据不存在不会增加;count 数据也会增加该值,count数据量多少,则增加多少

***_metric_filteredReadRequestCount

使用过滤的读请求数

***_metric_writeRequestCount

写请求数量

***_metric_compactionsQueuedCount

压缩队列大小

***_metric_maxCompactionQueueSize

该region最大一次Compaction队列大小

***_metric_maxFlushQueueSize

该region最大一次MemStore刷新队列数量

***_metric_flushesQueuedCount

当前MemStore Flush 队列数量

***_metric_maxStoreFileAge

storeFile存在最大时间,单位ms

***_metric_minStoreFileAge

storeFile存在最小时间,单位ms

***_metric_avgStoreFileAge

storeFile存在平均时间,单位ms

***_metric_lastMajorCompactionAge

最后一次执行MajorCompaction时间距离现在多久,单位毫秒

***_metric_putCountput数据次数,重复数据也会增加该值
***_metric_deleteCount删除数据次数
***_metric_scanCountscan数据次数;count也会增加该值,注意是后台查询的次数,比如 count 'tbName',{CACHE=>500},count 'tbName',{CACHE=>1000}执行的次数是不同的
***_metric_getCountget查询数据次数
***_metric_appendCount 
***_metric_incrementCount 

 

 

更多参数获取逻辑可阅读源码

实现类:org.apache.hadoop.hbase.regionserver.MetricsRegionWrapperImpl

http://hbase.apache.org/devapidocs/org/apache/hadoop/hbase/regionserver/MetricsRegionWrapperImpl.html

举例:获取 maxStoreFileAge,在org.apache.hadoop.hbase.regionserver.HStroe 类中

@Override
public long getMaxStoreFileAge() {long earliestTS = Long.MAX_VALUE;for (StoreFile s: this.storeEngine.getStoreFileManager().getStorefiles()) {StoreFile.Reader r = s.getReader();if (r == null) {LOG.warn("StoreFile " + s + " has a null Reader");continue;}if (!s.isHFile()) {continue;}long createdTS = s.getFileInfo().getCreatedTimestamp();earliestTS = (createdTS < earliestTS) ? createdTS : earliestTS;}long now = EnvironmentEdgeManager.currentTime();return now - earliestTS;
}

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/509785.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

String、StringBuilder和StringBuffer的区别和用法

分别使用使用这三种来拼接字符串&#xff0c;对比各自损耗的时间&#xff1a; 经过测试&#xff1a; package com.test;public class Main{public static void main(String[] args){testString();testStringBuffer();testStringBuilder();}private static void testStringBui…

Hbase Compaction 源码分析 - CompactionChecker

其他相关文章 Hbase Compaction 源码分析 - CompactionChecker Hbase Compaction 源码分析 - RatioBasedCompactionPolicy 策略 Hbase Compaction 源码分析 - CompactSplitThread 线程池选择 CompactionChecker 介绍&#xff1a; RegionServer会在后台启动一个线程Compac…

c++ 之类的前置声明

转自&#xff1a;http://blog.csdn.net/fjb2080/archive/2010/04/27/5533514.aspx 作者&#xff1a;清林&#xff0c;博客名&#xff1a;飞空静渡 刚开始学习c的人都会遇到这样的问题&#xff1a; 定义一个类 class A&#xff0c;这个类里面使用了类B的对象b&#xff0c;然后定…

java中随机数Random和ThreadLocalRandom()用法与区别

package com.test;import java.util.Random; import java.util.concurrent.ThreadLocalRandom;public class M1001{public static void main(String[] args) {Random random new Random();System.out.println("-----------产生1到10之间的随机数----------------");…

Hbase Compaction 源码分析 - RatioBasedCompactionPolicy 策略

目录 类的关系图 ​ RatioBasedCompactionPolicy selectCompaction 方法 getCurrentEligibleFiles方法 skipLargeFiles方法 createCompactionRequest方法 filterBulk方法 applyCompactionPolicy方法 removeExcessFiles方法 setIsMajor方法 其他相关文章 Hbase Compa…

Hbase Compaction 源码分析 - CompactSplitThread 线程池选择

目录 CompactSplitThread requestCompactionInternal方法 selectCompaction方法 requestCompaction方法 其他相关文章 Hbase Compaction 源码分析 - CompactionChecker Hbase Compaction 源码分析 - RatioBasedCompactionPolicy 策略 Hbase Compaction 源码分析 - CompactS…

java如何生成验证码

package com.test;import java.util.Random; import java.util.UUID; import java.util.concurrent.ThreadLocalRandom;public class M1001{public static void main(String[] args) {System.out.println("-----------产生5个随机数的验证码----------------");Strin…

m3u8下载ts 合并成一个视频

我们在用网页看视频时&#xff0c;很多时候视频是下载不下来的&#xff0c;当然这里面有很多技术来防止我们下载视频&#xff0c;接下来我将破解使用m3u8格式来下载视频。一般情况下&#xff0c;我们使用浏览器中Network来查看服务器和本机的数据传输&#xff0c;而视频的原地址…

用行为树的方式思考问题

这段时间做了很多和AI无关的事情&#xff0c;做了个Flash的3D引擎&#xff0c;用汇编写了些shader&#xff0c;做了很多引擎的工具&#xff0c;脚本&#xff0c;插件&#xff0c;游戏也发布了首个预告片&#xff0c;一年多的工作收获满满&#xff0c;职位从AI Engineer变成了En…

Linux常用指令2

linux的命令操作 1、日常操作命令 **查看当前所在的工作目录 pwd **查看当前系统的时间 date **查看有谁在线&#xff08;哪些人登陆到了服务器&#xff09; who 查看当前在线 last 查看最近的登陆历史记录 2、文件系统操作 ** ls / 查看根目录下的子节点&#xff…

qt, connect参数,Qt::DirectConnection,Qt::QueuedConnection

connect用于连接qt的信号和槽&#xff0c;在qt编程过程中不可或缺。它其实有第五个参数&#xff0c;只是一般使用默认值&#xff0c;在满足某些特殊需求的时候可能需要手动设置。 Qt::AutoConnection&#xff1a; 默认值&#xff0c;使用这个值则连接类型会在信号发送时决定。如…

Hbase Compaction 队列数量较大分析

目录 问题 问题原因分析 总结建议 问题 前几天朋友公司Hbase集群出现Compaction队列持续处于比较大的情况&#xff0c;并且mem flush队列也比较大&#xff0c;一起看了下问题&#xff0c;大概情况如下图 从图中可以看出来压缩队列总和持续在1000-2000&#xff0c;平对压缩队列…

java中Date和DateFormat、SimpleDateFormat类

package com.test;import java.text.DateFormat; import java.util.Date; import java.util.Random; import java.util.UUID; import java.util.concurrent.ThreadLocalRandom;public class M1001{public static void main(String[] args) {//Date表示特定的瞬间,精确到毫秒Dat…

Hbase 2.x Region in transition (永久RIT) 异常解决

环境 Hbase 版本&#xff1a;2.0 问题原因 hbase长时间出现RIT&#xff0c;并且发生RIT的Region是已经删除了的Hbase表&#xff0c;表未删除的情况下执行assgin可以消除该问题 Hbase Region in transition (RIT) 异常解决&#xff1a;https://datamining.blog.csdn.net/artic…

sigslot库源码分析

言归正传&#xff0c;sigslot是一个用标准C语法实现的信号与槽机制的函数库&#xff0c;类型和线程安全。提到信号与槽机制&#xff0c;恐怕最容易想到的就是大名鼎鼎的Qt所支持的对象之间通信的模式吧。不过这里的信号与槽虽然在概念上等价与Qt所实现的信号与槽&#xff0c;但…

Mysql for linux 安装

Mysql for linux 安装&#xff1a; 第一步&#xff0c;参考这个链接至第四步为止 https://jingyan.baidu.com/article/cd4c2979209c32756e6e60e1.html 第二步&#xff1a;使用rpm -qa | grep mysql 查询安装状态 第三步&#xff1a;使用/etc/rc.d/init.d/mysqld status 检…

Hue开发指南 - 提交 Spark 程序

目录 Hue开发指南 1.Spark文件打包成一个Jar包提交Hue运行 1.1 上传Spark Jar包至HDFS文件系统 1.2.Hue中创建Spark任务 2.多jar包导入执行&#xff08;依赖jar包与主程序jar包分开打包&#xff09; 2.1 修改worksapce 2.2 添加程序依赖jar包 Hue开发指南 Hue是面向 Had…

如何缩小码农和高手的差距

为什么同样的时间有的人可以漂亮的完成工作&#xff0c;而有些人废了很大的力气也没有完成&#xff1f;前者我们常常称之为“大牛”&#xff0c;后者我们常常叫他们“菜鸟”。当然“大牛”都是相对而言的&#xff0c;“大牛”也不可能方方面面都非常厉害&#xff0c;换句话说大…

OpenResty 安装,收集日志保存到文本文件

目录 安装 1.安装相关类库 2.安装编译openresty 3.编写配置启动openresty服务 4.通过 openresty 保存日志数据到系统 安装 1.安装相关类库 yum install -y readline-devel pcre-devel openssl-devel gcc 2.安装编译openresty wget https://openresty.org/download/open…

暗时间-领悟

作者&#xff1a;排长链接&#xff1a;https://www.zhihu.com/question/20689852/answer/23227406来源&#xff1a;知乎著作权归作者所有&#xff0c;转载请联系作者获得授权。第一次看到“暗时间”这个词&#xff0c;我的第一反应是有点不屑&#xff0c;又是一个概念噱头吧。直…