diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/ChainSpecificTimeWindowSummary.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/ChainSpecificTimeWindowSummary.java index b1b296d31..426ca1853 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/ChainSpecificTimeWindowSummary.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/ChainSpecificTimeWindowSummary.java @@ -39,7 +39,7 @@ public class ChainSpecificTimeWindowSummary { chainNodeSummaryResultMap.put(chainNodeSummaryResult.getTraceLevelId(), chainNodeSummaryResult); } - public void summaryResult(ChainNode node) { + public void summaryNodeValue(ChainNode node) { String tlid = node.getTraceLevelId(); ChainNodeSpecificTimeWindowSummary chainNodeSummaryResult = chainNodeSummaryResultMap.get(tlid); if (chainNodeSummaryResult == null) { diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/ChainSummary.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/ChainSummary.java index be6804648..900eb6c3d 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/ChainSummary.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/ChainSummary.java @@ -14,24 +14,22 @@ import java.util.Date; public class ChainSummary { - private Map summaryResultMap; + private Map loadedChainSpecificTimeWindowSummary; private Map updateChainInfo; public ChainSummary() { - summaryResultMap = new HashMap(); + loadedChainSpecificTimeWindowSummary = new HashMap(); updateChainInfo = new HashMap(); } public void summary(ChainInfo chainInfo) { for (ChainNode node : chainInfo.getNodes()) { String csk = generateChainSummaryKey(chainInfo.getCID(), node.getStartDate()); - ChainSpecificTimeWindowSummary chainSummaryResult = summaryResultMap.get(csk); - if (chainSummaryResult == null) { - chainSummaryResult = ChainSpecificTimeWindowSummary.load(csk); - summaryResultMap.put(csk, chainSummaryResult); + if (loadedChainSpecificTimeWindowSummary.containsKey(csk)) { + loadedChainSpecificTimeWindowSummary.put(csk, ChainSpecificTimeWindowSummary.load(csk)); } - summaryResultMap.get(csk).summaryResult(node); + loadedChainSpecificTimeWindowSummary.get(csk).summaryNodeValue(node); } updateChainInfo.put(chainInfo.getCID(), new Timestamp(System.currentTimeMillis())); @@ -44,16 +42,16 @@ public class ChainSummary { public void save() throws IOException, InterruptedException, SQLException { batchSaveChainSpecificTimeWindowSummary(); - batchUpdateChainDetail(); + updateChainLastActiveTime(); } - private void batchUpdateChainDetail() throws SQLException { - DBCallChainInfoDao.updateChainDetail(updateChainInfo); + private void updateChainLastActiveTime() throws SQLException { + DBCallChainInfoDao.updateChainLastActiveTime(updateChainInfo); } private void batchSaveChainSpecificTimeWindowSummary() throws IOException, InterruptedException { List puts = new ArrayList(); - for (Map.Entry entry : summaryResultMap.entrySet()) { + for (Map.Entry entry : loadedChainSpecificTimeWindowSummary.entrySet()) { Put put = new Put(entry.getKey().getBytes()); entry.getValue().save(put); puts.add(put); diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/DBCallChainInfoDao.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/DBCallChainInfoDao.java index 6e109667a..760829068 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/DBCallChainInfoDao.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/categorize2chain/DBCallChainInfoDao.java @@ -61,7 +61,7 @@ public class DBCallChainInfoDao { connection.commit(); } - public synchronized static void updateChainDetail(Map updateChainInfo) + public synchronized static void updateChainLastActiveTime(Map updateChainInfo) throws SQLException { PreparedStatement preparedStatement = null; try {