etrace-consumer 太过爱你忘了你带给我的痛 2023-03-02 10:26 6阅读 0赞 callstack和dal callstack先通过不同的analyzer list（里面可能分析具体trace，写hbase，kafka等） 然后入hdfs，hbase CallStack入hbase： rowKey：reqId，column：rpcId，value：ip+threadId+hour+blockOffset+messageOffset+rpcInfo(含不少信息) CallStack入hdfs：ip+threadId(1)+hour- hdfs文件名，blockOffset+messageOffset定位CallStack consumer拿到trace聚合后的metric写入hbase（ts和tags全部写入rowkey），端上请求可能interval不是最细粒度(10s),tags不是最细粒度，所以能匹配多条记录(时间通过范围scan，tags通过正则匹配，tag的key，value写入用hashcode（int）)，拿到多个采样数据 esm\_kv 解析后转换为callstack，然后入hdfs，hbase
还没有评论，来说两句吧...