kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复#32

This commit is contained in:
ascrutae 2016-02-21 22:30:03 +08:00
parent 531e7470e3
commit 683ab87924
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java
View File

@ -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 {