You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2019/02/12 11:30:35 UTC

[incubator-skywalking] branch top-sql updated: Add time bucket to persistent.

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch top-sql
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git


The following commit(s) were added to refs/heads/top-sql by this push:
     new e21b640  Add time bucket to persistent.
e21b640 is described below

commit e21b640f4d994c33b625df110b44dd19e97b0a43
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Tue Feb 12 19:30:27 2019 +0800

    Add time bucket to persistent.
---
 .../oap/server/core/analysis/manual/database/TopNDatabaseStatement.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/database/TopNDatabaseStatement.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/database/TopNDatabaseStatement.java
index e43d89a..2456486 100644
--- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/database/TopNDatabaseStatement.java
+++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/database/TopNDatabaseStatement.java
@@ -65,6 +65,7 @@ public class TopNDatabaseStatement extends TopN {
             statement.setTraceId((String)dbMap.get(TRACE_ID));
             statement.setLatency(((Number)dbMap.get(LATENCY)).longValue());
             statement.setServiceId(((Number)dbMap.get(SERVICE_ID)).intValue());
+            statement.setTimeBucket(((Number)dbMap.get(TIME_BUCKET)).longValue());
             return statement;
         }
 
@@ -74,6 +75,7 @@ public class TopNDatabaseStatement extends TopN {
             map.put(TRACE_ID, storageData.getTraceId());
             map.put(LATENCY, storageData.getLatency());
             map.put(SERVICE_ID, storageData.getServiceId());
+            map.put(TIME_BUCKET, storageData.getTimeBucket());
             return map;
         }
     }