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 <[email protected]>
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