From 41d3d894cf76dddd9e0fc7cce2166ba5aa44a42a Mon Sep 17 00:00:00 2001 From: "zhang.xin" Date: Wed, 9 Mar 2016 19:01:51 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9HBase=E4=B8=AD=E7=BB=9F?= =?UTF-8?q?=E8=AE=A1=E8=A1=A8=E4=B8=AD=E7=9A=84Rowkey=E6=9C=88=E4=BB=BD?= =?UTF-8?q?=E6=98=BE=E7=A4=BA=E4=B8=8D=E5=AF=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../chainbuild/entity/CallChainTreeNode.java | 22 ++++++------------- 1 file changed, 7 insertions(+), 15 deletions(-) diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTreeNode.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTreeNode.java index 8638ef58a..0a635c76a 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTreeNode.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTreeNode.java @@ -1,28 +1,20 @@ package com.ai.cloud.skywalking.analysis.chainbuild.entity; -import java.io.IOException; -import java.util.ArrayList; -import java.util.Calendar; -import java.util.Date; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import org.apache.hadoop.hbase.client.Put; - import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode; import com.ai.cloud.skywalking.analysis.chainbuild.util.HBaseUtil; import com.ai.cloud.skywalking.analysis.config.HBaseTableMetaData; import com.google.gson.GsonBuilder; import com.google.gson.annotations.Expose; +import org.apache.hadoop.hbase.client.Put; + +import java.io.IOException; +import java.util.*; /** - * * 调用树的每个traceLevelId + "@" + viewPointId构成一个树节点
* 虚拟化节点概念。节点存储落地时,按照节点对应的时间戳
- * - * @author wusheng * + * @author wusheng */ public class CallChainTreeNode { @Expose @@ -60,7 +52,7 @@ public class CallChainTreeNode { } private String generateKeyOfMinSummaryTable(String treeId, Calendar calendar) { - return treeId + "/" + calendar.get(Calendar.YEAR) + "-" + calendar.get(Calendar.MONTH) + "-" + return treeId + "/" + calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-" + calendar.get(Calendar.DAY_OF_MONTH) + " " + calendar.get(Calendar.HOUR) + ":00:00"; } @@ -74,7 +66,7 @@ public class CallChainTreeNode { * hbase的key 为 treeId + 小时
* 列族中,列为节点id,规则为:traceLevelId + "@" + viewPointId
* 列的值,为当前节点按小时内各分钟的汇总
- * + * * @throws IOException * @throws InterruptedException */