ops / yoho-trace-analyzer · Commits

Go to a project

Authored by wangning
Commit 1fc76ff93d2cea2124cedb3479d9b32421b78c43 1 parent e35a47cd

udpate

Inline Side-by-side
Showing 1 changed file with 6 additions and 0 deletions
@@ -426,7 +426,13 @@ public class TraceAnalyzeHandler implements TraceHandler, Serializable { @@ -426,7 +426,13 @@ public class TraceAnalyzeHandler implements TraceHandler, Serializable {
426 put.addColumn(Bytes.toBytes("data"), Bytes.toBytes("traceid"), Bytes.toBytes(apiTraceResult.getTraceId())); 426 put.addColumn(Bytes.toBytes("data"), Bytes.toBytes("traceid"), Bytes.toBytes(apiTraceResult.getTraceId()));
427 put.addColumn(Bytes.toBytes("data"), Bytes.toBytes("starttime"), Bytes.toBytes(apiTraceResult.getTraceStartTime()/1000)); 427 put.addColumn(Bytes.toBytes("data"), Bytes.toBytes("starttime"), Bytes.toBytes(apiTraceResult.getTraceStartTime()/1000));
428 428
  429 +
  430 + Put put2 = new Put(Bytes.toBytes(apiTraceResult.getApiName() + ":" + apiTraceResult.getTraceStartTime()/1000 + ":" + apiTraceResult.getTraceId()));
  431 + put2.addColumn(Bytes.toBytes("data"), Bytes.toBytes("spans"), Bytes.toBytes(JSONObject.toJSONString(apiTraceResult.getSpans())));
  432 + put2.addColumn(Bytes.toBytes("data"), Bytes.toBytes("traceid"), Bytes.toBytes(apiTraceResult.getTraceId()));
  433 + put2.addColumn(Bytes.toBytes("data"), Bytes.toBytes("starttime"), Bytes.toBytes(apiTraceResult.getTraceStartTime()/1000));
429 putList.add(put); 434 putList.add(put);
  435 + putList.add(put2);
430 } 436 }
431 437
432 resultTable.put(putList); 438 resultTable.put(putList);