From b8045d0d50663fbbea8f9d0d7732ca011c291c89 Mon Sep 17 00:00:00 2001 From: zhangxin10 Date: Wed, 18 Nov 2015 22:05:39 +0800 Subject: [PATCH] =?UTF-8?q?RPC=E7=9A=84=E6=9C=8D=E5=8A=A1=E7=AB=AF?= =?UTF-8?q?=E5=9F=8B=E7=82=B9=E7=9A=84Column=E5=8A=A0=E4=B8=8AS?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../reciever/storage/chain/SaveToHBaseChain.java | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 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 7e92e7ece..e6f23b8c3 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 @@ -98,14 +98,23 @@ public class SaveToHBaseChain implements IStorageChain { return; List puts = new ArrayList(); Put put; + String columnName; for (BuriedPointEntry buriedPointEntry : entries) { put = new Put(Bytes.toBytes(buriedPointEntry.getTraceId())); if (StringUtils.isEmpty(buriedPointEntry.getParentLevel().trim())) { - put.addColumn(Bytes.toBytes(Config.HBaseConfig.FAMILY_COLUMN_NAME), Bytes.toBytes(String.valueOf(buriedPointEntry.getLevelId())), + columnName = buriedPointEntry.getLevelId() + ""; + if (buriedPointEntry.isReceiver()) { + columnName = buriedPointEntry.getLevelId() + "-S"; + } + put.addColumn(Bytes.toBytes(Config.HBaseConfig.FAMILY_COLUMN_NAME), Bytes.toBytes(columnName), Bytes.toBytes(buriedPointEntry.getOriginData())); } else { - put.addColumn(Bytes.toBytes(Config.HBaseConfig.FAMILY_COLUMN_NAME), Bytes.toBytes(buriedPointEntry.getParentLevel() - + "." + buriedPointEntry.getLevelId()), Bytes.toBytes(buriedPointEntry.getOriginData())); + columnName = buriedPointEntry.getParentLevel() + "." + buriedPointEntry.getLevelId(); + if (buriedPointEntry.isReceiver()) { + columnName = buriedPointEntry.getLevelId() + "-S"; + } + put.addColumn(Bytes.toBytes(Config.HBaseConfig.FAMILY_COLUMN_NAME), Bytes.toBytes(columnName), + Bytes.toBytes(buriedPointEntry.getOriginData())); } puts.add(put); }