[incubator-iotdb] branch file_size_monitor updated: format code

[liurui]

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

liurui pushed a commit to branch file_size_monitor
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/file_size_monitor by this push:
     new dceb5a3  format code
dceb5a3 is described below

commit dceb5a388ffaf311e248304a4bf0a685727f42d3
Author: liuruiyiyang <245422...@qq.com>
AuthorDate: Sat Mar 9 17:34:02 2019 +0800

    format code
---
 .../main/java/org/apache/iotdb/db/monitor/MonitorConstants.java  | 1 +
 iotdb/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java | 3 +++
 .../java/org/apache/iotdb/db/monitor/collector/FileSize.java     | 9 ++++-----
 3 files changed, 8 insertions(+), 5 deletions(-)

diff --git 
a/iotdb/src/main/java/org/apache/iotdb/db/monitor/MonitorConstants.java 
b/iotdb/src/main/java/org/apache/iotdb/db/monitor/MonitorConstants.java
index f8472b1..ec899c8 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/monitor/MonitorConstants.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/monitor/MonitorConstants.java
@@ -28,6 +28,7 @@ import org.apache.iotdb.db.monitor.collector.FileSize;
 import org.apache.iotdb.db.service.Monitor;
 
 public class MonitorConstants {
+
   private static IoTDBConfig config = 
IoTDBDescriptor.getInstance().getConfig();
   public static final String DATA_TYPE_INT64 = "INT64";
   public static final String STAT_STORAGE_GROUP_PREFIX = "root.stats";
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java 
b/iotdb/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java
index 6008f41..a9a5355 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java
@@ -152,6 +152,7 @@ public class StatMonitor implements IService {
 
   /**
    * register monitor statistics time series metadata into MManager.
+   *
    * @param hashMap series path and data type pair, for example: 
[root.stat.file.size.DATA, INT64]
    */
   public synchronized void registerStatStorageGroup(Map<String, String> 
hashMap) {
@@ -194,6 +195,7 @@ public class StatMonitor implements IService {
 
   /**
    * register class which implemented IStatistic interface into statisticMap
+   *
    * @param path the stat series prefix path, like root.stat.file.size
    * @param iStatistic instance of class which implemented IStatistic interface
    */
@@ -336,6 +338,7 @@ public class StatMonitor implements IService {
   }
 
   class StatBackLoop implements Runnable {
+
     FileSize fileSize = FileSize.getInstance();
 
     @Override
diff --git 
a/iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java 
b/iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
index eb6dfa0..f3e3ffe 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
@@ -71,12 +71,11 @@ public class FileSize implements IStatistic {
   public void registerStatMetadata() {
     Map<String, String> hashMap = new HashMap<>();
     for (FileSizeConstants kind : FileSizeConstants.values()) {
-      hashMap.put(MonitorConstants.FILE_SIZE_STORAGE_GROUP_NAME
+      String seriesPath = MonitorConstants.FILE_SIZE_STORAGE_GROUP_NAME
           + MonitorConstants.MONITOR_PATH_SEPARATOR
-          + kind.name(), MonitorConstants.DATA_TYPE_INT64);
-      Path path = new Path(MonitorConstants.FILE_SIZE_STORAGE_GROUP_NAME
-          + MonitorConstants.MONITOR_PATH_SEPARATOR
-          + kind.name());
+          + kind.name();
+      hashMap.put(seriesPath, MonitorConstants.DATA_TYPE_INT64);
+      Path path = new Path(seriesPath);
       try {
         fileNodeManager.addTimeSeries(path, 
TSDataType.valueOf(MonitorConstants.DATA_TYPE_INT64),
             TSEncoding.valueOf("RLE"), 
CompressionType.valueOf(TSFileConfig.compressor),