You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ej...@apache.org on 2021/05/21 19:39:13 UTC
[iotdb] branch dynamic_compaction updated: finish hitter
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 024b266 finish hitter
024b266 is described below
commit 024b266b12f56603250990078e1da5d1388a14c0
Author: EJTTianyu <16...@qq.com>
AuthorDate: Sat May 22 03:38:44 2021 +0800
finish hitter
---
.../level/hitter/HitterLevelCompactionTsFileManagement.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
index 2761feb..7b004a7 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
@@ -125,7 +125,7 @@ public class HitterLevelCompactionTsFileManagement extends LevelCompactionTsFile
File newLevelFile = createTempTsFileName(mergeResources.get(i).get(0).getTsFile());
TsFileResource newResource = new TsFileResource(newLevelFile);
// merge, read heavy hitters time series from source files and write to target file
- List<PartialPath> unmergedPaths = QueryHitterManager.getQueryHitter()
+ List<PartialPath> unmergedPaths = QueryHitterManager.getInstance().getQueryHitter()
.getTopCompactionSeries(new PartialPath(storageGroupName));
long st = System.nanoTime();
CompactionUtils
@@ -267,7 +267,7 @@ public class HitterLevelCompactionTsFileManagement extends LevelCompactionTsFile
File newLevelFile = createNewTsFileName(mergeResources.get(i).get(0).getTsFile(), i + 1);
TsFileResource newResource = new TsFileResource(newLevelFile);
// merge, read heavy hitters time series from source files and write to target file
- List<PartialPath> unmergedPaths = QueryHitterManager.getQueryHitter()
+ List<PartialPath> unmergedPaths = QueryHitterManager.getInstance().getQueryHitter()
.getTopCompactionSeries(new PartialPath(storageGroupName));
long st = System.nanoTime();
CompactionUtils