提交 1c545a37 编写于 作者: 彭勇升 pengys 提交者: wu-sheng

Fixed a time series bug about downsampling setting in processors are different...

Fixed a time series bug about downsampling setting in processors are different from the setting in receivers. (#2856)

#2851
上级 ec731b2a
...@@ -65,7 +65,7 @@ public class RecordStreamProcessor implements StreamProcessor<Record> { ...@@ -65,7 +65,7 @@ public class RecordStreamProcessor implements StreamProcessor<Record> {
} }
IModelSetter modelSetter = moduleDefineHolder.find(CoreModule.NAME).provider().getService(IModelSetter.class); IModelSetter modelSetter = moduleDefineHolder.find(CoreModule.NAME).provider().getService(IModelSetter.class);
Model model = modelSetter.putIfAbsent(recordClass, stream.scopeId(), new Storage(stream.name(), true, true, Downsampling.Minute)); Model model = modelSetter.putIfAbsent(recordClass, stream.scopeId(), new Storage(stream.name(), true, true, Downsampling.Second));
RecordPersistentWorker persistentWorker = new RecordPersistentWorker(moduleDefineHolder, model, 1000, recordDAO); RecordPersistentWorker persistentWorker = new RecordPersistentWorker(moduleDefineHolder, model, 1000, recordDAO);
persistentWorkers.add(persistentWorker); persistentWorkers.add(persistentWorker);
......
...@@ -61,7 +61,7 @@ public class TopNStreamProcessor implements StreamProcessor<TopN> { ...@@ -61,7 +61,7 @@ public class TopNStreamProcessor implements StreamProcessor<TopN> {
} }
IModelSetter modelSetter = moduleDefineHolder.find(CoreModule.NAME).provider().getService(IModelSetter.class); IModelSetter modelSetter = moduleDefineHolder.find(CoreModule.NAME).provider().getService(IModelSetter.class);
Model model = modelSetter.putIfAbsent(topNClass, stream.scopeId(), new Storage(stream.name(), true, true, Downsampling.Minute)); Model model = modelSetter.putIfAbsent(topNClass, stream.scopeId(), new Storage(stream.name(), true, true, Downsampling.Second));
TopNWorker persistentWorker = new TopNWorker(moduleDefineHolder, model, 50, recordDAO); TopNWorker persistentWorker = new TopNWorker(moduleDefineHolder, model, 50, recordDAO);
persistentWorkers.add(persistentWorker); persistentWorkers.add(persistentWorker);
......
...@@ -33,8 +33,8 @@ public class ModelName { ...@@ -33,8 +33,8 @@ public class ModelName {
return modelName + Const.ID_SPLIT + Downsampling.Day.getName(); return modelName + Const.ID_SPLIT + Downsampling.Day.getName();
case Hour: case Hour:
return modelName + Const.ID_SPLIT + Downsampling.Hour.getName(); return modelName + Const.ID_SPLIT + Downsampling.Hour.getName();
case Second: // case Second:
return modelName + Const.ID_SPLIT + Downsampling.Second.getName(); // return modelName + Const.ID_SPLIT + Downsampling.Second.getName();
default: default:
return modelName; return modelName;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册