From 683ab87924949b5134330064818381e88f6073e1 Mon Sep 17 00:00:00 2001
From: ascrutae <ascrutae@gmail.com>
Date: Sun, 21 Feb 2016 22:30:03 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D#32?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../reciever/storage/chain/SaveToHBaseChain.java          | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java
index 66fb9389c..05bcb6d62 100644
--- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java
+++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java
@@ -73,14 +73,14 @@ public class SaveToHBaseChain implements IStorageChain {
 
     }
 
-    private static void bulkInsertBuriedPointData(List<Span> spans) {
+    public static void bulkInsertBuriedPointData(List<Span> spans) {
         if (spans == null || spans.size() <= 0)
             return;
         List<Put> puts = new ArrayList<Put>();
         Put put;
         String columnName;
         for (Span span : spans) {
-            put = new Put(Bytes.toBytes(span.getTraceId()));
+            put = new Put(Bytes.toBytes(span.getTraceId()), getTSBySpanTraceId(span));
             if (StringUtils.isEmpty(span.getParentLevel().trim())) {
                 columnName = span.getLevelId() + "";
                 if (span.isReceiver()) {
@@ -104,6 +104,10 @@ public class SaveToHBaseChain implements IStorageChain {
         ServerHealthCollector.getCurrentHeathReading("hbase").updateData(ServerHeathReading.INFO, "save " + spans.size() + " BuriedPointEntries.");
     }
 
+    private static long getTSBySpanTraceId(Span span) {
+        return Long.parseLong(span.getTraceId().split("\\.")[2]);
+    }
+
     private static void bulkInsertBuriedPointData(String tableName, List<Put> data) {
         Object[] resultArrays = new Object[data.size()];
         try {