[iotdb] branch dynamic_compaction updated: hitter L=4

[ejttianyu]

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

ejttianyu pushed a commit to branch dynamic_compaction
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dynamic_compaction by this 
push:
     new f418e66  hitter L=4
f418e66 is described below

commit f418e6694fbb77da4d6ad80977501278c90984e6
Author: EJTTianyu <1653503...@qq.com>
AuthorDate: Fri Apr 2 20:54:52 2021 +0800

    hitter L=4
---
 .../iotdb/db/engine/heavyhitter/hitter/DefaultHitter.java      | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/heavyhitter/hitter/DefaultHitter.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/heavyhitter/hitter/DefaultHitter.java
index e85f3f6..39dd9f8 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/heavyhitter/hitter/DefaultHitter.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/heavyhitter/hitter/DefaultHitter.java
@@ -19,7 +19,9 @@
 
 package org.apache.iotdb.db.engine.heavyhitter.hitter;
 
+import java.util.ArrayList;
 import java.util.List;
+import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import org.apache.iotdb.db.engine.heavyhitter.QueryHeavyHitters;
 import org.apache.iotdb.db.exception.metadata.MetadataException;
 import org.apache.iotdb.db.metadata.MManager;
@@ -49,6 +51,14 @@ public class DefaultHitter implements QueryHeavyHitters {
     if (devicePaths.size() > 0) {
       String deviceName = devicePaths.get(0).get(0).getDevice();
       logger.info("default hitter, top compaction device:{}", deviceName);
+      if (IoTDBDescriptor.getInstance().getConfig().getMaxHitterNum() == -1) {
+        List<PartialPath> devicePath = devicePaths.get(0);
+        List<PartialPath> ret = new ArrayList<>();
+        for (int i = 0; i < devicePath.size() / 2; i++) {
+          ret.add(devicePath.get(i));
+        }
+        return ret;
+      }
       return devicePaths.get(0);
     }
     return null;