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

Invoke the function in indicator to calculate result and persistent to storage.

This commit is contained in:
peng-yongsheng 2018-08-20 11:09:24 +08:00
parent d39b6baf35
commit 77e5b65b53
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/IndicatorPersistentWorker.java
View File

@ -122,8 +122,11 @@ public class IndicatorPersistentWorker extends AbstractWorker<Indicator> {
private void cacheData(Indicator input) {
mergeDataCache.writing();
if (mergeDataCache.containsKey(input)) {
mergeDataCache.get(input).combine(input);
Indicator indicator = mergeDataCache.get(input);
indicator.combine(input);
indicator.calculate();
} else {
input.calculate();
mergeDataCache.put(input);
}