You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/03/17 10:32:11 UTC
[iotdb] 04/04: use partitionLatestFlushedTimeForEachDevice instead of newlyFlushedPartitionLatestFlushedTimeForEachDevice
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch QueryImprove
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cadd8512c534252f9fb97f606122cc922b5571c4
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Fri Mar 17 18:31:49 2023 +0800
use partitionLatestFlushedTimeForEachDevice instead of newlyFlushedPartitionLatestFlushedTimeForEachDevice
---
.../org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java
index 5c337d4709..dbcfe60f31 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java
@@ -253,7 +253,7 @@ public class HashLastFlushTimeMap implements ILastFlushTimeMap {
@Override
public List<Long> getAllSatisfiedTimePartitions(String deviceId, Filter timeFilter) {
if (deviceId == null) {
- return newlyFlushedPartitionLatestFlushedTimeForEachDevice.keySet().stream()
+ return partitionLatestFlushedTimeForEachDevice.keySet().stream()
.filter(
stringLongMap -> {
long[] startAndEndTime =
@@ -263,7 +263,7 @@ public class HashLastFlushTimeMap implements ILastFlushTimeMap {
})
.collect(Collectors.toList());
} else {
- return newlyFlushedPartitionLatestFlushedTimeForEachDevice.entrySet().stream()
+ return partitionLatestFlushedTimeForEachDevice.entrySet().stream()
.filter(
entry -> {
long[] startAndEndTime =